[
https://issues.apache.org/jira/browse/DISPATCH-68?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jack Gibson updated DISPATCH-68:
--------------------------------
Description: Create system tests and examples to demonstrate distributed
durable topics. (was: ## Setup the broker as such:
## qpid-config add queue myBarQ
## qpid-config -a localhost:5673 add queue myBarQ
##
## qpid-config add queue yourBarQ
## qpid-config -a localhost:5673 add queue yourBarQ
##
## qpid-config bind amq.topic myBarQ *.bar
## qpid-config -a localhost:5673 bind amq.topic myBarQ *.bar
##
## qpid-config bind amq.topic yourBarQ *.bar
## qpid-config -a localhost:5673bind amq.topic yourBarQ *.bar
##
## On the router node:
## spout --connection-options {protocol:amqp1.0} -b 0.0.0.0:5672 -c 1000
amq.topic/foo.bar
## ./drain --connection-options {protocol:amqp1.0} -c 1000 myBarQ | wc -l
## ./drain --connection-options {protocol:amqp1.0} -c 1000 yourBarQ | wc -l
##
## On the broker node:
## qpid-stat -q && qpid-stat -q -b localhost:5673
##
## myBarQ and yourBarQ should have 1000 msgIn, 1000 msgOut and 0 msg
## amq.topic should have 1000 msgIn, 1000 msgOut and 0 droppedMsg
container {
worker-threads: 4
container-name: Qpid.Dispatch.Router.router01
}
ssl-profile {
name: ssl-profile-name
}
listener {
addr: 0.0.0.0
port: 5672
sasl-mechanisms: ANONYMOUS
max-frame-size: 16384
}
connector {
name: broker1
role: on-demand
addr: 10.64.242.218
port: 5672
sasl-mechanisms: ANONYMOUS
}
connector {
name: broker2
role: on-demand
addr: 10.64.242.218
port: 5673
sasl-mechanisms: ANONYMOUS
}
router {
mode: standalone
router-id: Mammut.router01
}
waypoint {
address: amq.topic
out-phase: 1
in-phase: 0
connector: broker1
}
waypoint {
address: amq.topic
out-phase: 1
in-phase: 0
connector: broker2
}
waypoint {
address: myBarQ
out-phase: 1
in-phase: 0
connector: broker1
}
waypoint {
address: myBarQ
out-phase: 1
in-phase: 0
connector: broker2
}
waypoint {
address: yourBarQ
out-phase: 1
in-phase: 0
connector: broker1
}
waypoint {
address: yourBarQ
out-phase: 1
in-phase: 0
connector: broker2
}
fixed-address {
prefix: amq.topic
phase: 0
fanout: single
bias: spread
}
fixed-address {
prefix: yourBarQ
phase: 1
fanout: single
bias: spread
}
fixed-address {
prefix: myBarQ
phase: 1
fanout: single
bias: spread
})
## Setup the broker as such:
## qpid-config add queue myBarQ
## qpid-config -a localhost:5673 add queue myBarQ
##
## qpid-config add queue yourBarQ
## qpid-config -a localhost:5673 add queue yourBarQ
##
## qpid-config bind amq.topic myBarQ *.bar
## qpid-config -a localhost:5673 bind amq.topic myBarQ *.bar
##
## qpid-config bind amq.topic yourBarQ *.bar
## qpid-config -a localhost:5673bind amq.topic yourBarQ *.bar
##
## On the router node:
## spout --connection-options {protocol:amqp1.0} -b 0.0.0.0:5672 -c 1000
amq.topic/foo.bar
## ./drain --connection-options {protocol:amqp1.0} -c 1000 myBarQ | wc -l
## ./drain --connection-options {protocol:amqp1.0} -c 1000 yourBarQ | wc -l
##
## On the broker node:
## qpid-stat -q && qpid-stat -q -b localhost:5673
##
## myBarQ and yourBarQ should have 1000 msgIn, 1000 msgOut and 0 msg
## amq.topic should have 1000 msgIn, 1000 msgOut and 0 droppedMsg
container {
worker-threads: 4
container-name: Qpid.Dispatch.Router.router01
}
ssl-profile {
name: ssl-profile-name
}
listener {
addr: 0.0.0.0
port: 5672
sasl-mechanisms: ANONYMOUS
max-frame-size: 16384
}
connector {
name: broker1
role: on-demand
addr: 10.64.242.218
port: 5672
sasl-mechanisms: ANONYMOUS
}
connector {
name: broker2
role: on-demand
addr: 10.64.242.218
port: 5673
sasl-mechanisms: ANONYMOUS
}
router {
mode: standalone
router-id: Mammut.router01
}
waypoint {
address: amq.topic
out-phase: 1
in-phase: 0
connector: broker1
}
waypoint {
address: amq.topic
out-phase: 1
in-phase: 0
connector: broker2
}
waypoint {
address: myBarQ
out-phase: 1
in-phase: 0
connector: broker1
}
waypoint {
address: myBarQ
out-phase: 1
in-phase: 0
connector: broker2
}
waypoint {
address: yourBarQ
out-phase: 1
in-phase: 0
connector: broker1
}
waypoint {
address: yourBarQ
out-phase: 1
in-phase: 0
connector: broker2
}
fixed-address {
prefix: amq.topic
phase: 0
fanout: single
bias: spread
}
fixed-address {
prefix: yourBarQ
phase: 1
fanout: single
bias: spread
}
fixed-address {
prefix: myBarQ
phase: 1
fanout: single
bias: spread
}
> Add distributed topic test and documentation
> --------------------------------------------
>
> Key: DISPATCH-68
> URL: https://issues.apache.org/jira/browse/DISPATCH-68
> Project: Qpid Dispatch
> Issue Type: Test
> Components: Documentation, Tests
> Affects Versions: 0.3
> Reporter: Jack Gibson
> Priority: Trivial
> Fix For: 0.3
>
> Original Estimate: 1h
> Remaining Estimate: 1h
>
> Create system tests and examples to demonstrate distributed durable topics.
--
This message was sent by Atlassian JIRA
(v6.2#6252)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
