Jack Gibson created DISPATCH-68:
-----------------------------------
Summary: 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
## 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
}
--
This message was sent by Atlassian JIRA
(v6.2#6252)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
