Skip to content

0.8v goes stable. #238

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 69 commits into from
Oct 19, 2017
Merged
Changes from 1 commit
Commits
Show all changes
69 commits
Select commit Hold shift + click to select a range
3325424
[dbal] Performance improvements and new features.
makasim Sep 13, 2017
24a73df
require 0.8.x
makasim Sep 13, 2017
5850b7f
fix phpstan issues.
makasim Sep 13, 2017
b928422
fix tests.
makasim Sep 13, 2017
19fef9a
Merge pull request #199 from php-enqueue/dbal-improvements
makasim Sep 13, 2017
c4cf691
allow subtree split branch which does not exist.
makasim Sep 13, 2017
ac81bca
[fs] fix bugs intrdoced in #181.
makasim Sep 20, 2017
bdfdaf6
Merge pull request #203 from php-enqueue/fs-edge-case-with-message-si…
makasim Sep 20, 2017
e570724
[doc] add file paths in code examples.
makasim Sep 22, 2017
a8129bb
Merge branch 'master' into 0.8
makasim Sep 25, 2017
9cb59d6
[dsn] replace xxx:// to xxx:
makasim Sep 25, 2017
2673504
upd docs.
makasim Sep 25, 2017
387b1da
[doc] add dsn_to_context usage example
makasim Sep 25, 2017
69674da
[dsn] fix tests. clean up docs.
makasim Sep 25, 2017
240f932
fix tests.
makasim Sep 25, 2017
9df787b
Merge pull request #205 from php-enqueue/dsn-get-rid-of-two-slashes
makasim Sep 26, 2017
c0b9a40
Merge remote-tracking branch 'origin/master' into 0.8
makasim Sep 26, 2017
c212a9e
Merge branch 'master' into 0.8
makasim Sep 28, 2017
d401385
Merge remote-tracking branch 'origin/master' into 0.8
makasim Oct 3, 2017
fcee9a0
[amqp-ext] Add basic consume method.
makasim Oct 10, 2017
30fd704
[consumption] queue consumer should use amqp basic consume if amqp co…
makasim Oct 10, 2017
fee8fc5
fixes
makasim Oct 10, 2017
71a525a
[consumption] fix echange cound not be decalred, no channel.
makasim Oct 10, 2017
ffa585e
Merge branch 'master' into 0.8
makasim Oct 10, 2017
3789423
Merge branch '0.8' into amqp-add-basic-consume-support
makasim Oct 10, 2017
e52b476
[amqp-ext] move basic consume logic to context.
makasim Oct 10, 2017
c5ee3a6
[amqp-ext] move basic consume methods to context.
makasim Oct 10, 2017
8dfda8f
[amqp-bunny] implement basic consume related methods.
makasim Oct 10, 2017
69634d7
[amqp-lib] Add basic consume support.
makasim Oct 11, 2017
81460cc
require amqp interop 0.7 ver
makasim Oct 11, 2017
4f79870
require 0.5.1 spec in all amqp rel pkg.
makasim Oct 11, 2017
dd9038b
fix phpstan issues.
makasim Oct 11, 2017
e03f49b
Merge pull request #217 from php-enqueue/amqp-add-basic-consume-support
makasim Oct 11, 2017
4e3e01a
Merge branch 'master' into 0.8
makasim Oct 11, 2017
9db4a14
Fix type error
makasim Oct 11, 2017
d6fd457
Merge branch 'master' into 0.8
makasim Oct 11, 2017
cf572cf
[amqp-bunny] use timestamp as int. bunny uses datetime.
makasim Oct 11, 2017
7968b03
[amqp(s)] Use same qos options across all amqp transports.
makasim Oct 11, 2017
d9fa256
req queue spec 0.5.2
makasim Oct 11, 2017
e69c1e6
[doc] add --skip option to the doc
makasim Oct 11, 2017
98316ac
Merge pull request #221 from php-enqueue/amqp-use-same-qos-options-in…
makasim Oct 11, 2017
b695dff
[amqp-bunny] fixes and impr related to basic consume feature.
makasim Oct 12, 2017
e4d894f
[amqp-lib] The context should allow to get the lib's channel.
makasim Oct 12, 2017
f4ca543
[amqp-lib] fixes and impr for basic consume feature.
makasim Oct 12, 2017
a8c288b
[amqp-ext] fixes and impr for basic consume feature.
makasim Oct 12, 2017
c2d1dab
[amqp-bunny] purge queues in specs.
makasim Oct 12, 2017
814443d
upd queue spec req
makasim Oct 12, 2017
e5af40a
Merge pull request #223 from php-enqueue/amqp-basic-consume-fixes
makasim Oct 12, 2017
36d9bbf
[amqp-ext] AmqpProducer::send must throw only interop exception.
makasim Oct 12, 2017
7b0bf16
[amqp-ext] Restore default read timeout inside consume callback.
makasim Oct 12, 2017
8e729ed
Merge branch 'master' into 0.8
makasim Oct 12, 2017
b1cb420
Merge branch 'master' into 0.8
makasim Oct 13, 2017
6a80a7c
[BC break][amqp] Introduce connection config. Make it same accross al…
makasim Oct 13, 2017
f7f6cc0
[amqp] ConnectionConfig::addSupportedSchemes -> addSupportedScheme
makasim Oct 13, 2017
f1ff387
Introduce generic amqp\rabbitmq transport factories.
makasim Oct 13, 2017
efd269f
[client] fix simple client tests
makasim Oct 14, 2017
040eb5a
[doc] upd config ref doc.
makasim Oct 14, 2017
5ac1602
[amqp-bunny] ignore broken pipe exception in __destruct()
makasim Oct 14, 2017
5b632ef
Merge pull request #228 from php-enqueue/amqp-connection-config
makasim Oct 14, 2017
f97c796
Merge remote-tracking branch 'origin/master' into 0.8
makasim Oct 17, 2017
56191ea
[amqp] One single transport factory for all supported amqp implementa…
makasim Oct 17, 2017
804afc5
Merge branch 'amqp-shared-transport-factory' into 0.8
makasim Oct 17, 2017
359ef8a
[consumption][amqp] move beforeReceive call at the end of the cycle f…
makasim Oct 17, 2017
dd23112
Merge pull request #234 from php-enqueue/queue-consumer-amqp-and-befo…
makasim Oct 17, 2017
4e1dc9f
[amqp-bunny] throw only queue interop exception on Producer::send();
makasim Oct 18, 2017
fe99c93
[amqp-lib] throw only queue interop exception on Producer::send();
makasim Oct 18, 2017
5988285
Merge branch '0.8' of github.com:php-enqueue/enqueue-dev into 0.8
makasim Oct 18, 2017
46eff71
Merge branch 'master' into 0.8
makasim Oct 19, 2017
dc2a470
try fixing tests on travis.
makasim Oct 19, 2017
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
249 changes: 175 additions & 74 deletions docs/bundle/config_reference.md
Original file line number Diff line number Diff line change
@@ -38,149 +38,201 @@ enqueue:

# The option tells whether RabbitMQ broker has delay plugin installed or not
delay_plugin_installed: false
amqp:
amqp_ext:

# The connection to AMQP broker set as a string. Other parameters are ignored if set
# The connection to AMQP broker set as a string. Other parameters could be used as defaults
dsn: ~

# The host to connect too. Note: Max 1024 characters
host: localhost
host: ~

# Port on the host.
port: 5672
port: ~

# The user name to use. Note: Max 128 characters.
user: guest
user: ~

# Password. Note: Max 128 characters.
pass: guest
pass: ~

# The virtual host on the host. Note: Max 128 characters.
vhost: /
vhost: ~

# Connection timeout. Note: 0 or greater seconds. May be fractional.
connect_timeout: ~
connection_timeout: ~

# Timeout in for income activity. Note: 0 or greater seconds. May be fractional.
read_timeout: ~

# Timeout in for outcome activity. Note: 0 or greater seconds. May be fractional.
write_timeout: ~
persisted: false
lazy: true

# How often to send heartbeat. 0 means off.
heartbeat: ~
persisted: ~
lazy: ~

# The receive strategy to be used. We suggest to use basic_consume as it is more performant. Though you need AMQP extension 1.9.1 or higher
receive_method: basic_get # One of "basic_get"; "basic_consume"
rabbitmq_amqp:
receive_method: ~ # One of "basic_get"; "basic_consume"

# The server will send a message in advance if it is equal to or smaller in size than the available prefetch size. May be set to zero, meaning "no specific limit"
qos_prefetch_size: ~

# Specifies a prefetch window in terms of whole messages
qos_prefetch_count: ~

# If "false" the QoS settings apply to the current channel only. If this field is "true", they are applied to the entire connection.
qos_global: ~

# The options that are specific to the amqp transport you chose. For example amqp+lib have insist, keepalive, stream options. amqp+bunny has tcp_nodelay extra option.
driver_options: ~
rabbitmq_amqp_ext:

# The connection to AMQP broker set as a string. Other parameters are ignored if set
# The connection to AMQP broker set as a string. Other parameters could be used as defaults
dsn: ~

# The host to connect too. Note: Max 1024 characters
host: localhost
host: ~

# Port on the host.
port: 5672
port: ~

# The user name to use. Note: Max 128 characters.
user: guest
user: ~

# Password. Note: Max 128 characters.
pass: guest
pass: ~

# The virtual host on the host. Note: Max 128 characters.
vhost: /
vhost: ~

# Connection timeout. Note: 0 or greater seconds. May be fractional.
connect_timeout: ~
connection_timeout: ~

# Timeout in for income activity. Note: 0 or greater seconds. May be fractional.
read_timeout: ~

# Timeout in for outcome activity. Note: 0 or greater seconds. May be fractional.
write_timeout: ~
persisted: false
lazy: true

# How often to send heartbeat. 0 means off.
heartbeat: ~
persisted: ~
lazy: ~

# The receive strategy to be used. We suggest to use basic_consume as it is more performant. Though you need AMQP extension 1.9.1 or higher
receive_method: basic_get # One of "basic_get"; "basic_consume"
receive_method: ~ # One of "basic_get"; "basic_consume"

# The server will send a message in advance if it is equal to or smaller in size than the available prefetch size. May be set to zero, meaning "no specific limit"
qos_prefetch_size: ~

# Specifies a prefetch window in terms of whole messages
qos_prefetch_count: ~

# If "false" the QoS settings apply to the current channel only. If this field is "true", they are applied to the entire connection.
qos_global: ~

# The options that are specific to the amqp transport you chose. For example amqp+lib have insist, keepalive, stream options. amqp+bunny has tcp_nodelay extra option.
driver_options: ~

# The delay strategy to be used. Possible values are "dlx", "delayed_message_plugin" or service id
delay_strategy: dlx
amqp_lib:

# The connection to AMQP broker set as a string. Other parameters are ignored if set
# The connection to AMQP broker set as a string. Other parameters could be used as defaults
dsn: ~

# The host to connect too. Note: Max 1024 characters
host: localhost
host: ~

# Port on the host.
port: 5672
port: ~

# The user name to use. Note: Max 128 characters.
user: guest
user: ~

# Password. Note: Max 128 characters.
pass: guest
pass: ~

# The virtual host on the host. Note: Max 128 characters.
vhost: /
vhost: ~

# Connection timeout. Note: 0 or greater seconds. May be fractional.
connection_timeout: !!float 3
read_write_timeout: !!float 3
connection_timeout: ~

# Timeout in for income activity. Note: 0 or greater seconds. May be fractional.
read_timeout: 3
read_timeout: ~

# Timeout in for outcome activity. Note: 0 or greater seconds. May be fractional.
write_timeout: 3
lazy: true
stream: true
insist: false
keepalive: false
write_timeout: ~

# How often to send heartbeat. 0 means off.
heartbeat: ~
persisted: ~
lazy: ~

# The receive strategy to be used. We suggest to use basic_consume as it is more performant. Though you need AMQP extension 1.9.1 or higher
receive_method: basic_get # One of "basic_get"; "basic_consume"
heartbeat: 0
receive_method: ~ # One of "basic_get"; "basic_consume"

# The server will send a message in advance if it is equal to or smaller in size than the available prefetch size. May be set to zero, meaning "no specific limit"
qos_prefetch_size: ~

# Specifies a prefetch window in terms of whole messages
qos_prefetch_count: ~

# If "false" the QoS settings apply to the current channel only. If this field is "true", they are applied to the entire connection.
qos_global: ~

# The options that are specific to the amqp transport you chose. For example amqp+lib have insist, keepalive, stream options. amqp+bunny has tcp_nodelay extra option.
driver_options: ~
rabbitmq_amqp_lib:

# The connection to AMQP broker set as a string. Other parameters are ignored if set
# The connection to AMQP broker set as a string. Other parameters could be used as defaults
dsn: ~

# The host to connect too. Note: Max 1024 characters
host: localhost
host: ~

# Port on the host.
port: 5672
port: ~

# The user name to use. Note: Max 128 characters.
user: guest
user: ~

# Password. Note: Max 128 characters.
pass: guest
pass: ~

# The virtual host on the host. Note: Max 128 characters.
vhost: /
vhost: ~

# Connection timeout. Note: 0 or greater seconds. May be fractional.
connection_timeout: !!float 3
read_write_timeout: !!float 3
connection_timeout: ~

# Timeout in for income activity. Note: 0 or greater seconds. May be fractional.
read_timeout: 3
read_timeout: ~

# Timeout in for outcome activity. Note: 0 or greater seconds. May be fractional.
write_timeout: 3
lazy: true
stream: true
insist: false
keepalive: false
write_timeout: ~

# How often to send heartbeat. 0 means off.
heartbeat: ~
persisted: ~
lazy: ~

# The receive strategy to be used. We suggest to use basic_consume as it is more performant. Though you need AMQP extension 1.9.1 or higher
receive_method: basic_get # One of "basic_get"; "basic_consume"
heartbeat: 0
receive_method: ~ # One of "basic_get"; "basic_consume"

# The server will send a message in advance if it is equal to or smaller in size than the available prefetch size. May be set to zero, meaning "no specific limit"
qos_prefetch_size: ~

# Specifies a prefetch window in terms of whole messages
qos_prefetch_count: ~

# If "false" the QoS settings apply to the current channel only. If this field is "true", they are applied to the entire connection.
qos_global: ~

# The options that are specific to the amqp transport you chose. For example amqp+lib have insist, keepalive, stream options. amqp+bunny has tcp_nodelay extra option.
driver_options: ~

# The delay strategy to be used. Possible values are "dlx", "delayed_message_plugin" or service id
delay_strategy: dlx
@@ -197,6 +249,9 @@ enqueue:

# The queue files are created with this given permissions if not exist.
chmod: 384

# How often query for new messages.
polling_interval: 100
redis:

# can be a host, or the path to a unix domain socket
@@ -240,52 +295,100 @@ enqueue:
lazy: true
amqp_bunny:

# The connection to AMQP broker set as a string. Other parameters are ignored if set
# The connection to AMQP broker set as a string. Other parameters could be used as defaults
dsn: ~

# The host to connect too. Note: Max 1024 characters
host: localhost
host: ~

# Port on the host.
port: 5672
port: ~

# The user name to use. Note: Max 128 characters.
user: guest
user: ~

# Password. Note: Max 128 characters.
pass: guest
pass: ~

# The virtual host on the host. Note: Max 128 characters.
vhost: /
lazy: true
vhost: ~

# Connection timeout. Note: 0 or greater seconds. May be fractional.
connection_timeout: ~

# Timeout in for income activity. Note: 0 or greater seconds. May be fractional.
read_timeout: ~

# Timeout in for outcome activity. Note: 0 or greater seconds. May be fractional.
write_timeout: ~

# How often to send heartbeat. 0 means off.
heartbeat: ~
persisted: ~
lazy: ~

# The receive strategy to be used. We suggest to use basic_consume as it is more performant. Though you need AMQP extension 1.9.1 or higher
receive_method: basic_get # One of "basic_get"; "basic_consume"
heartbeat: 0
receive_method: ~ # One of "basic_get"; "basic_consume"

# The server will send a message in advance if it is equal to or smaller in size than the available prefetch size. May be set to zero, meaning "no specific limit"
qos_prefetch_size: ~

# Specifies a prefetch window in terms of whole messages
qos_prefetch_count: ~

# If "false" the QoS settings apply to the current channel only. If this field is "true", they are applied to the entire connection.
qos_global: ~

# The options that are specific to the amqp transport you chose. For example amqp+lib have insist, keepalive, stream options. amqp+bunny has tcp_nodelay extra option.
driver_options: ~
rabbitmq_amqp_bunny:

# The connection to AMQP broker set as a string. Other parameters are ignored if set
# The connection to AMQP broker set as a string. Other parameters could be used as defaults
dsn: ~

# The host to connect too. Note: Max 1024 characters
host: localhost
host: ~

# Port on the host.
port: 5672
port: ~

# The user name to use. Note: Max 128 characters.
user: guest
user: ~

# Password. Note: Max 128 characters.
pass: guest
pass: ~

# The virtual host on the host. Note: Max 128 characters.
vhost: /
lazy: true
vhost: ~

# Connection timeout. Note: 0 or greater seconds. May be fractional.
connection_timeout: ~

# Timeout in for income activity. Note: 0 or greater seconds. May be fractional.
read_timeout: ~

# Timeout in for outcome activity. Note: 0 or greater seconds. May be fractional.
write_timeout: ~

# How often to send heartbeat. 0 means off.
heartbeat: ~
persisted: ~
lazy: ~

# The receive strategy to be used. We suggest to use basic_consume as it is more performant. Though you need AMQP extension 1.9.1 or higher
receive_method: basic_get # One of "basic_get"; "basic_consume"
heartbeat: 0
receive_method: ~ # One of "basic_get"; "basic_consume"

# The server will send a message in advance if it is equal to or smaller in size than the available prefetch size. May be set to zero, meaning "no specific limit"
qos_prefetch_size: ~

# Specifies a prefetch window in terms of whole messages
qos_prefetch_count: ~

# If "false" the QoS settings apply to the current channel only. If this field is "true", they are applied to the entire connection.
qos_global: ~

# The options that are specific to the amqp transport you chose. For example amqp+lib have insist, keepalive, stream options. amqp+bunny has tcp_nodelay extra option.
driver_options: ~

# The delay strategy to be used. Possible values are "dlx", "delayed_message_plugin" or service id
delay_strategy: dlx
@@ -313,8 +416,6 @@ enqueue:
doctrine_clear_identity_map_extension: false
signal_extension: true
reply_extension: true


```
[back to index](../index.md)