Hello Ram,

I just tried to reproduce your issue but was not successful.
I ran a 6.0.2 broker (with default config) and trunk clients.
I created 30 producers on their own connections and sent 10k persistent messages each in its own transaction. After hitting 634,583,040 B direct memory usage flow to disk kicked in and the direct memory usage leveled off. I monitored the log for the QUE-1014 and BRK-1014 messages to verify that the broker starts flowing messages to disk and I monitored the direct memory usage with jvisualvm. I attached my hacked together test client application, the log file and a screenshot showing the direct memory usage.

Can you see something that you are using differently? Can you create a minimal example that exposes the problem that you could share with me?

Note that monitoring disk usage as a measure of whether flow to disk is active is not going to work when you have persistent messages because in this case messages are always written to disk regardless of flow to disk.

Kind regards,
Lorenz


On 18/10/16 03:10, rammohan ganapavarapu wrote:
please let me know if u need any thing else.

On Oct 17, 2016 11:02 AM, "rammohan ganapavarapu" <rammohanga...@gmail.com>
wrote:

Lorenz,


Actually message size vary between ~ 1kb to 10k

Thanks,
Ram

On Mon, Oct 17, 2016 at 10:23 AM, rammohan ganapavarapu <
rammohanga...@gmail.com> wrote:

Lorenz,

Thanks for trying to help, Please find the below answers for your
questions.


Q:What is the type of your virtualhost (Derby, BDB, ...)?

A: Derby ( i actually wanted to know your recomendation)

Q: How large are your messages? Do they vary in size or all the same size?

A: Message size is approximately 1k

Q: How many connections/sessions/producers/consumers are connected to
the broker?

A: we are using 3 producers and each have 10 connections.

Q: Are there any consumers active while you are testing?

A: No, we blocked all the consumers
Q: Do you use transactions?
A: They are transnational but ack is done immediately after accepting, if
fails we push it back to dl queue.
Q: Are the messages persistent or transient?
A: They are persistent.

Ram

On Mon, Oct 17, 2016 at 1:15 AM, Lorenz Quack <quack.lor...@gmail.com>
wrote:

Hello Ram,

This seems curious.
Yes, the idea behind flow to disk is to prevent the broker from running
out of direct memory.
The broker does keep a certain representation of the message in memory
but that should affect heap and not direct memory.

I currently do not understand what is happening here so I raised a JIRA
[1].

Could you provide some more information about your test case so I can
try to reproduce it on my end?
What is the type of your virtualhost (Derby, BDB, ...)?
How large are your messages? Do they vary in size or all the same size?
How many connections/sessions/producers/consumers are connected to the
broker?
Are there any consumers active while you are testing?
Do you use transactions?
Are the messages persistent or transient?

Kind regards,
Lorenz

[1] https://issues.apache.org/jira/browse/QPID-7461



On 14/10/16 19:14, rammohan ganapavarapu wrote:

Hi,

I am confused with flow to disk context, when direct memory reaches
flow to
disk threshold, broker directly write to disk or it keep in both memory
and
disk? i was in the impression that flow to disk threshold to free up
direct
memory so that broker wont crash, isn't it?

So i have 1.5gb direct memory and here is my flow to disk threshodl

"broker.flowToDiskThreshold":"644245094"  (40% as default)

I am pushing messages and after 40% of direct memory messages are
writing
to disk as you can see disk space is going up but my question is when
its
writing to disk shouldn't it free up direct memory? but i see direct
memory
usage is also going up, am i missing any thing here?


broker1 | success | rc=0 >>
/data   50G  754M   46G   2% /ebs
Fri Oct 14 17:59:25 UTC 2016
    "maximumDirectMemorySize" : 1610612736,
      "usedDirectMemorySize" : 840089280,

broker1 | success | rc=0 >>
/data   50G  761M   46G   2% /ebs
Fri Oct 14 17:59:27 UTC 2016
    "maximumDirectMemorySize" : 1610612736,
      "usedDirectMemorySize" : 843497152,

.
.
.
/data   50G  1.3G   46G   3% /ebs
Fri Oct 14 18:09:08 UTC 2016
    "maximumDirectMemorySize" : 1610612736,
      "usedDirectMemorySize" : 889035136,


Please help me understand this!

Thanks,
Ram



On Fri, Oct 14, 2016 at 9:22 AM, rammohan ganapavarapu <
rammohanga...@gmail.com> wrote:

So i ran the test few more times and it is happening every time, i was
monitoring direct memory usage and looks like it ran out of direct
memory.

    "maximumDirectMemorySize" : 2415919104,
      "usedDirectMemorySize" : 2414720896,

Any thoughts guys?

Ram

On Thu, Oct 13, 2016 at 4:37 PM, rammohan ganapavarapu <
rammohanga...@gmail.com> wrote:

Guys,
Not sure what i am doing wrong, i have set heap to 1gb and direct mem
to
2gb after ~150k msgs queuedepth  in the queue i am getting bellow
error and
broker is getting killed. Any suggestions?

2016-10-13 23:27:41,894 ERROR [IO-/10.16.1.34:46096] (o.a.q.s.Main) -
Uncaught exception, shutting down.
java.lang.OutOfMemoryError: Direct buffer memory
          at java.nio.Bits.reserveMemory(Bits.java:658) ~[na:1.7.0_75]
          at java.nio.DirectByteBuffer.<ini
t>(DirectByteBuffer.java:123)
~[na:1.7.0_75]
          at java.nio.ByteBuffer.allocateDirect(ByteBuffer.java:306)
~[na:1.7.0_75]

2016-10-13 23:27:41,894 ERROR [IO-/10.16.1.34:46096] (o.a.q.s.Main) -
Uncaught exception, shutting down.
java.lang.OutOfMemoryError: Direct buffer memory
          at java.nio.Bits.reserveMemory(Bits.java:658) ~[na:1.7.0_75]
          at java.nio.DirectByteBuffer.<ini
t>(DirectByteBuffer.java:123)
~[na:1.7.0_75]
          at java.nio.ByteBuffer.allocateDirect(ByteBuffer.java:306)
~[na:1.7.0_75]
          at org.apache.qpid.bytebuffer.Qpi
dByteBuffer.allocateDirect(QpidByteBuffer.java:469)
~[qpid-common-6.0.2.jar:6.0.2]
          at org.apache.qpid.bytebuffer.Qpi
dByteBuffer.allocateDirect(QpidByteBuffer.java:482)
~[qpid-common-6.0.2.jar:6.0.2]
          at org.apache.qpid.server.protoco
l.v0_10.ServerEncoder.init(ServerEncoder.java:57)
~[qpid-broker-plugins-amqp-0-10-protocol-6.0.2.jar:6.0.2]
          at org.apache.qpid.server.protocol.v0_10.ServerDisassembler.
method(ServerDisassembler.java:196) ~[qpid-broker-plugins-amqp-0-1
0-protocol-6.0.2.jar:6.0.2]
          at org.apache.qpid.server.protocol.v0_10.ServerDisassembler.
control(ServerDisassembler.java:185) ~[qpid-broker-plugins-amqp-0-1
0-protocol-6.0.2.jar:6.0.2]
          at org.apache.qpid.server.protocol.v0_10.ServerDisassembler.
control(ServerDisassembler.java:57) ~[qpid-broker-plugins-amqp-0-1
0-protocol-6.0.2.jar:6.0.2]
          at org.apache.qpid.transport.Meth
od.delegate(Method.java:159)
~[qpid-common-6.0.2.jar:6.0.2]
          at org.apache.qpid.server.protocol.v0_10.ServerDisassembler.
send(ServerDisassembler.java:79) ~[qpid-broker-plugins-amqp-0-1
0-protocol-6.0.2.jar:6.0.2]
          at org.apache.qpid.transport.Conn
ection.send(Connection.java:415)
~[qpid-common-6.0.2.jar:6.0.2]
          at org.apache.qpid.server.protoco
l.v0_10.ServerConnection.send(ServerConnection.java:497)
~[qpid-broker-plugins-amqp-0-10-protocol-6.0.2.jar:6.0.2]
          at org.apache.qpid.transport.Session.send(Session.java:588)
~[qpid-common-6.0.2.jar:6.0.2]
          at org.apache.qpid.transport.Sess
ion.invoke(Session.java:804)
~[qpid-common-6.0.2.jar:6.0.2]
          at org.apache.qpid.transport.Sess
ion.invoke(Session.java:613)
~[qpid-common-6.0.2.jar:6.0.2]
          at org.apache.qpid.transport.Sess
ionInvoker.sessionCompleted(SessionInvoker.java:65)
~[qpid-common-6.0.2.jar:6.0.2]
          at org.apache.qpid.transport.Sess
ion.flushProcessed(Session.java:514)
~[qpid-common-6.0.2.jar:6.0.2]
          at org.apache.qpid.server.protoco
l.v0_10.ServerSessionDelegate.
command(ServerSessionDelegate.java:119)
~[qpid-broker-plugins-amqp-0-1
0-protocol-6.0.2.jar:6.0.2]
          at org.apache.qpid.server.protoco
l.v0_10.ServerSessionDelegate.
command(ServerSessionDelegate.java:87) ~[qpid-broker-plugins-amqp-0-1
0-protocol-6.0.2.jar:6.0.2]
          at org.apache.qpid.transport.Meth
od.delegate(Method.java:155)
~[qpid-common-6.0.2.jar:6.0.2]
          at org.apache.qpid.transport.Sess
ion.received(Session.java:582)
~[qpid-common-6.0.2.jar:6.0.2]
          at org.apache.qpid.transport.Conn
ection.dispatch(Connection.java:447)
~[qpid-common-6.0.2.jar:6.0.2]
          at org.apache.qpid.transport.Conn
ectionDelegate.handle(ConnectionDelegate.java:65)
~[qpid-common-6.0.2.jar:6.0.2]
          at org.apache.qpid.transport.Conn
ectionDelegate.handle(ConnectionDelegate.java:41)
~[qpid-common-6.0.2.jar:6.0.2]
          at org.apache.qpid.transport.Meth
odDelegate.executionSync(MethodDelegate.java:104)
~[qpid-common-6.0.2.jar:6.0.2]
          at org.apache.qpid.transport.Exec
utionSync.dispatch(ExecutionSync.java:82)
~[qpid-common-6.0.2.jar:6.0.2]
          at org.apache.qpid.transport.Conn
ectionDelegate.command(ConnectionDelegate.java:55)
~[qpid-common-6.0.2.jar:6.0.2]
          at org.apache.qpid.transport.Conn
ectionDelegate.command(ConnectionDelegate.java:41)
~[qpid-common-6.0.2.jar:6.0.2]
          at org.apache.qpid.transport.Meth
od.delegate(Method.java:155)
~[qpid-common-6.0.2.jar:6.0.2]
          at org.apache.qpid.transport.Conn
ection.received(Connection.java:400)
~[qpid-common-6.0.2.jar:6.0.2]
          at org.apache.qpid.server.protocol.v0_10.ServerConnection.
access$001(ServerConnection.java:72) ~[qpid-broker-plugins-amqp-0-1
0-protocol-6.0.2.jar:6.0.2]
          at org.apache.qpid.server.protoco
l.v0_10.ServerConnection$2.run(ServerConnection.java:277)
~[qpid-broker-plugins-amqp-0-10-protocol-6.0.2.jar:6.0.2]
          at org.apache.qpid.server.protoco
l.v0_10.ServerConnection$2.run(ServerConnection.java:273)
~[qpid-broker-plugins-amqp-0-10-protocol-6.0.2.jar:6.0.2]
          at java.security.AccessController.doPrivileged(Native
Method)
~[na:1.7.0_75]
          at org.apache.qpid.server.protocol.v0_10.ServerConnection.
received(ServerConnection.java:272) ~[qpid-broker-plugins-amqp-0-1
0-protocol-6.0.2.jar:6.0.2]
          at org.apache.qpid.server.protoco
l.v0_10.ServerAssembler.emit(ServerAssembler.java:122)
~[qpid-broker-plugins-amqp-0-10-protocol-6.0.2.jar:6.0.2]
          at org.apache.qpid.server.protocol.v0_10.ServerAssembler.
assemble(ServerAssembler.java:211) ~[qpid-broker-plugins-amqp-0-1
0-protocol-6.0.2.jar:6.0.2]
          at org.apache.qpid.server.protoco
l.v0_10.ServerAssembler.frame(ServerAssembler.java:151)
~[qpid-broker-plugins-amqp-0-10-protocol-6.0.2.jar:6.0.2]
          at org.apache.qpid.server.protocol.v0_10.ServerAssembler.
received(ServerAssembler.java:79) ~[qpid-broker-plugins-amqp-0-1
0-protocol-6.0.2.jar:6.0.2]
          at org.apache.qpid.server.protocol.v0_10.ServerInputHandler.
parse(ServerInputHandler.java:175) ~[qpid-broker-plugins-amqp-0-1
0-protocol-6.0.2.jar:6.0.2]
          at org.apache.qpid.server.protocol.v0_10.ServerInputHandler.
received(ServerInputHandler.java:82) ~[qpid-broker-plugins-amqp-0-1
0-protocol-6.0.2.jar:6.0.2]
          at org.apache.qpid.server.protoco
l.v0_10.AMQPConnection_0_10$3.
run(AMQPConnection_0_10.java:156) ~[qpid-broker-plugins-amqp-0-1
0-protocol-6.0.2.jar:6.0.2]
          at java.security.AccessController.doPrivileged(Native
Method)
~[na:1.7.0_75]
          at org.apache.qpid.server.protoco
l.v0_10.AMQPConnection_0_10.
received(AMQPConnection_0_10.java:148) ~[qpid-broker-plugins-amqp-0-1
0-protocol-6.0.2.jar:6.0.2]
          at org.apache.qpid.server.transpo
rt.MultiVersionProtocolEngine.

received(MultiVersionProtocolEngine.java:144)
~[qpid-broker-core-6.0.2.jar:6.0.2]
          at org.apache.qpid.server.transpo
rt.NonBlockingConnection.proce
ssAmqpData(NonBlockingConnection.java:609)
~[qpid-broker-core-6.0.2.jar:6
.0.2]
          at org.apache.qpid.server.transpo
rt.NonBlockingConnectionPlainD
elegate.processData(NonBlockingConnectionPlainDelegate.java:58)
~[qpid-broker-core-6.0.2.jar:6.0.2]
          at org.apache.qpid.server.transport.NonBlockingConnection.
doRead(NonBlockingConnection.java:503) ~[qpid-broker-core-6.0.2.jar:6
.0.2]
          at org.apache.qpid.server.transport.NonBlockingConnection.
doWork(NonBlockingConnection.java:282) ~[qpid-broker-core-6.0.2.jar:6
.0.2]
          at org.apache.qpid.server.transpo
rt.NetworkConnectionScheduler.
processConnection(NetworkConnectionScheduler.java:124)
~[qpid-broker-core-6.0.2.jar:6.0.2]
          at org.apache.qpid.server.transpo
rt.SelectorThread$ConnectionPr
ocessor.processConnection(SelectorThread.java:504)
~[qpid-broker-core-6.0.2.jar:6.0.2]
          at org.apache.qpid.server.transpo
rt.SelectorThread$SelectionTas
k.performSelect(SelectorThread.java:337)
~[qpid-broker-core-6.0.2.jar:6
.0.2]
          at org.apache.qpid.server.transpo
rt.SelectorThread$SelectionTask.run(SelectorThread.java:87)
~[qpid-broker-core-6.0.2.jar:6.0.2]
          at org.apache.qpid.server.transpo
rt.SelectorThread.run(SelectorThread.java:462)
~[qpid-broker-core-6.0.2.jar:6.0.2]
          at java.util.concurrent.ThreadPoo
lExecutor.runWorker(ThreadPoolExecutor.java:1145)
~[na:1.7.0_75]
          at java.util.concurrent.ThreadPoo
lExecutor$Worker.run(ThreadPoolExecutor.java:615)
~[na:1.7.0_75]
          at java.lang.Thread.run(Thread.java:745) ~[na:1.7.0_75]


Ram

On Thu, Oct 13, 2016 at 1:45 PM, Rob Godfrey <rob.j.godf...@gmail.com
wrote:

On 13 October 2016 at 19:54, rammohan ganapavarapu <
rammohanga...@gmail.com>
wrote:

Rob,
Understood, we are doing negative testing like what will happened to

broker

when all the consumers are down but producers are pumping messages,
so

i

was the in the impression that flow to disk threshold will avoid

broker go

bad because of OOM. So i have bumped up the heap and direct mem

setting of

broker and try to restart  but it was complaining with bellow error.



*2016-10-13 18:28:46,157 INFO  [Housekeeping[default]]
(q.m.q.flow_to_disk_active) - [Housekeeping[default]]
[vh(/default)/qu(ax-q-mxgroup001)] QUE-1014 : Message flow to disk

active

:  Message memory use 13124325 kB (13gb) exceeds threshold 168659 kB
(168mb)*


But actual flow to disk threshold from broker is as:

* "broker.flowToDiskThreshold" : "858993459", ( with is 40% of
direct-mem(2g))*

I know my message size is more than the threshold but i am trying to

see

how log message was saying 168mb.

So the broker takes its overall flow to disk "quota" and then
divides
this
up between virtual hosts, and for each virtual host divides up
between
the
queues on the virtual host.  This allows for some fairness when
multiple
virtual hosts or multiple queues are actually representing different
applications.  Individual queues thus may start flowing to disk even
though
the overall threshold has not yet been reached.


So to make broker running i have enabled background recovery and it
seems

working fine but  i am curious to know how broker dump back all the
messages from disk to memory does it dump all or does dump in
batches?

So on recovery, and also when an individual message has flowed to
disk,
the
broker simply reloads individual messages into memory when it needs
them
in
an on-demand basis.

Hope this helps,
Rob


Thanks,
Ram

On Thu, Oct 13, 2016 at 11:29 AM, Rob Godfrey <
rob.j.godf...@gmail.com

wrote:

On 13 October 2016 at 17:36, rammohan ganapavarapu <
rammohanga...@gmail.com>
wrote:

Lorenz,
Thank you for the link, so no matter how much heap you have you

will
hit

the hard limit at some point right?, i thought flow to disk will
make
broker not to crash because of out of memory issue but looks like
its
not

the case.
In my environment we will have dynamic number of producers and

consumers
so

its hard to pre measure how much heap we can allocate based on

number
of

connection/sessions.
Ram


Yeah - currently there is always a hard limit based on the number
of

"queue

entries".  Ultimately there's a trade-off to be had with designing
a

queue

data structure which is high performing, vs. one which can be

offloaded
onto disk.  This gets even more complicated for queues which are not
strict

FIFO (priority queues, LVQ, etc) or where consumers have selectors.
Ultimately if you are storing millions of messages in your broker

then
you

are probably doing things wrong - we would expect people to enforce

queue
limits and flow control rather than expect the broker to have
infinite
capacity (and even off-loading to disk you will still run out of
disk

space

at some point).

-- Rob



On Thu, Oct 13, 2016 at 9:05 AM, Lorenz Quack <

quack.lor...@gmail.com>
wrote:
Hello Ram,
may I refer you to the relevant section of the documentation [1].
As explained there in more detail, the broker keeps a

representation
of

each message in heap even when flowing the message to disk.
Therefore the amount of JVM heap memory puts a hard limit on the

number
of
message the broker can hold.

Kind Regards,
Lorenz

[1] https://qpid.apache.org/releases/qpid-java-6.0.4/java-broker
/book/Java-Broker-Runtime-Memory.html



On 13/10/16 16:40, rammohan ganapavarapu wrote:

Hi,
We are doing some load test using java broker 6.0.2 by stopping

all
consumers, broker was crashed at 644359 messages. Even if i try
to
restart
broker its crashing with the same oom error.
    "persistentEnqueuedBytes" : 12731167222,
       "persistentEnqueuedMessages" : 644359,
       "queueDepthBytes" : 12731167222,
       "queueDepthMessages" : 644359,
       "totalDequeuedBytes" : 0,
       "totalDequeuedMessages" : 0,
       "totalEnqueuedBytes" : 12731167222,
       "totalEnqueuedMessages" : 644359,

JVM settings of broker: -Xmx512m -XX:MaxDirectMemorySize=1536m

"broker.flowToDiskThreshold" : "644245094",

So theoretically broker should flow those messages to disk

after the
threshold right then broker shouldn't have caused OOM exception
right?
do
i
have to do any other tuning?

Thanks,
Ram


------------------------------------------------------------
---------
To unsubscribe, e-mail: users-unsubscr...@qpid.apache.org
For additional commands, e-mail: users-h...@qpid.apache.org



---------------------------------------------------------------------

To unsubscribe, e-mail: users-unsubscr...@qpid.apache.org
For additional commands, e-mail: users-h...@qpid.apache.org



2016-10-18 15:01:22,618 WARN  [Broker-Config] (o.a.q.s.m.ConfiguredObjectTypeRegistry) - A class definition could not be found while processing the model for 'org.apache.qpid.server.virtualhostnode.berkeleydb.BDBHAVirtualHostNodeImpl': com/sleepycat/je/DatabaseException
2016-10-18 15:01:22,706 WARN  [Broker-Config] (o.a.q.s.m.ConfiguredObjectTypeRegistry) - A class definition could not be found while processing the model for 'org.apache.qpid.server.virtualhost.berkeleydb.BDBHAVirtualHostImpl': com/sleepycat/je/rep/StateChangeListener
2016-10-18 15:01:23,017 INFO  [Broker-Config] (o.a.q.s.s.GenericStoreUpgrader) - Broker store has model version 6.0. Number of record(s) 19
2016-10-18 15:01:23,138 INFO  [Broker-Config] (q.m.a.create) - [Broker] ATH-1001 : Create "passwordFile"
2016-10-18 15:01:23,172 INFO  [Broker-Config] (q.m.p.create) - [Broker] PRT-1001 : Create "AMQP"
2016-10-18 15:01:23,173 INFO  [Broker-Config] (q.m.p.create) - [Broker] PRT-1001 : Create "HTTP"
2016-10-18 15:01:23,338 INFO  [Broker-Config] (q.m.b.config) - [Broker] BRK-1006 : Using configuration : /home/lorenz/qpid_work/ram2/config.json
2016-10-18 15:01:23,517 INFO  [Broker-Config] (q.m.b.startup) - [Broker] BRK-1001 : Startup : Version: 6.0.2 Build: 1738920
2016-10-18 15:01:23,519 INFO  [Broker-Config] (q.m.b.platform) - [Broker] BRK-1010 : Platform : JVM : Oracle Corporation version: 1.7.0_80-b15 OS : Linux version: 3.13.0-96-generic arch: i386 cores: 2
2016-10-18 15:01:23,522 INFO  [Broker-Config] (q.m.b.max_memory) - [Broker] BRK-1011 : Maximum Memory : Heap : 523,501,568 bytes Direct : 1,610,612,736 bytes
2016-10-18 15:01:23,523 INFO  [Broker-Config] (q.m.b.process) - [Broker] BRK-1017 : Process : PID : 8303
2016-10-18 15:01:23,667 INFO  [Broker-Config] (q.m.c.created) - [Broker] [vh(/default)/ms(JsonFileConfigStore)] CFG-1001 : Created
2016-10-18 15:01:23,668 INFO  [Broker-Config] (q.m.c.store_location) - [Broker] [vh(/default)/ms(JsonFileConfigStore)] CFG-1002 : Store location : /home/lorenz/qpid_work/ram2/default/config/
2016-10-18 15:01:23,668 INFO  [Broker-Config] (q.m.c.recovery_start) - [Broker] [vh(/default)/ms(JsonFileConfigStore)] CFG-1004 : Recovery Start
2016-10-18 15:01:23,675 INFO  [Broker-Config] (o.a.q.s.s.GenericStoreUpgrader) - VirtualHost store has model version 6.0. Number of record(s) 5
2016-10-18 15:01:23,683 INFO  [Broker-Config] (q.m.v.created) - [Broker] VHT-1001 : Created : default
2016-10-18 15:01:23,692 INFO  [Broker-Config] (q.m.c.recovery_complete) - [Broker] [vh(/default)/ms(JsonFileConfigStore)] CFG-1005 : Recovery Complete
2016-10-18 15:01:23,738 INFO  [VirtualHostNode-default-Config] (q.m.e.created) - [Broker] EXH-1001 : Create : Durable Type: fanout Name: amq.fanout
2016-10-18 15:01:23,738 INFO  [VirtualHostNode-default-Config] (q.m.e.created) - [Broker] EXH-1001 : Create : Durable Type: headers Name: amq.match
2016-10-18 15:01:23,739 INFO  [VirtualHostNode-default-Config] (q.m.e.created) - [Broker] EXH-1001 : Create : Durable Type: topic Name: amq.topic
2016-10-18 15:01:23,739 INFO  [VirtualHostNode-default-Config] (q.m.e.created) - [Broker] EXH-1001 : Create : Durable Type: direct Name: amq.direct
2016-10-18 15:01:23,748 INFO  [Broker-Config] (q.m.b.listening) - [Broker] BRK-1002 : Starting : Listening on TCP port 5672
2016-10-18 15:01:23,783 INFO  [Broker-Config] (q.m.m.startup) - [Broker] MNG-1001 : Web Management Startup
2016-10-18 15:01:24,410 WARN  [VirtualHostNode-default-Config] (DERBY) - os.name=Linux
os.arch=i386
os.version=3.13.0-96-generic

2016-10-18 15:01:25,082 INFO  [Broker-Config] (q.m.m.listening) - [Broker] MNG-1002 : Starting : HTTP : Listening on TCP port 8080
2016-10-18 15:01:25,091 INFO  [Broker-Config] (q.m.m.ready) - [Broker] MNG-1004 : Web Management Ready
2016-10-18 15:01:26,686 INFO  [VirtualHostNode-default-Config] (q.m.m.created) - [Broker] [vh(/default)/ms(DerbyMessageStore)] MST-1001 : Created
2016-10-18 15:01:26,687 INFO  [VirtualHostNode-default-Config] (q.m.m.store_location) - [Broker] [vh(/default)/ms(DerbyMessageStore)] MST-1002 : Store location : /home/lorenz/qpid_work/ram2/default/messages
2016-10-18 15:01:26,700 INFO  [VirtualHostNode-default-Config] (q.m.m.recovery_start) - [Broker] [vh(/default)/ms(DerbyMessageStore)] MST-1004 : Recovery Start
2016-10-18 15:01:26,709 INFO  [VirtualHostNode-default-Config] (q.m.t.recovery_start) - [Broker] [vh(/default)/ms(DerbyMessageStore)] TXN-1004 : Recovery Start
2016-10-18 15:01:26,727 INFO  [VirtualHostNode-default-Config] (q.m.t.recovery_complete) - [Broker] [vh(/default)/ms(DerbyMessageStore)] TXN-1006 : Recovery Complete
2016-10-18 15:01:26,728 INFO  [VirtualHostNode-default-Config] (q.m.m.recovered) - [Broker] [vh(/default)/ms(DerbyMessageStore)] MST-1005 : Recovered 0 messages
2016-10-18 15:01:26,729 INFO  [VirtualHostNode-default-Config] (q.m.m.recovery_complete) - [Broker] [vh(/default)/ms(DerbyMessageStore)] MST-1006 : Recovery Complete
2016-10-18 15:01:26,733 INFO  [Broker-Config] (q.m.b.ready) - [Broker] BRK-1004 : Qpid Broker Ready
2016-10-18 15:01:42,243 INFO  [IO-/127.0.0.1:52328] (q.m.c.open) - [con:0(/127.0.0.1:52328)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9
2016-10-18 15:01:43,529 INFO  [IO-/127.0.0.1:52328] (q.m.c.open) - [con:0(guest@/127.0.0.1:52328/default)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9 : Client ID : clientid : Client Version : 6.1.0-SNAPSHOT : Client Product : qpid
2016-10-18 15:01:43,796 INFO  [IO-/127.0.0.1:52328] (q.m.c.create) - [con:0(guest@/127.0.0.1:52328/default)/ch:1] CHN-1001 : Create
2016-10-18 15:01:43,832 INFO  [IO-/127.0.0.1:52328] (q.m.c.prefetch_size) - [con:0(guest@/127.0.0.1:52328/default)/ch:1] CHN-1004 : Prefetch Size (bytes) 0 : Count 3
2016-10-18 15:01:43,913 INFO  [IO-/127.0.0.1:52328] (q.m.c.flow) - [con:0(guest@/127.0.0.1:52328/default)/ch:1] [con:0(guest@/127.0.0.1:52328/default)/ch:1] CHN-1002 : Flow Stopped
2016-10-18 15:01:44,485 INFO  [IO-/127.0.0.1:52328] (q.m.c.flow) - [con:0(guest@/127.0.0.1:52328/default)/ch:1] [con:0(guest@/127.0.0.1:52328/default)/ch:1] CHN-1002 : Flow Started
2016-10-18 15:01:44,700 INFO  [IO-/127.0.0.1:52328] (q.m.c.close) - [con:0(guest@/127.0.0.1:52328/default)/ch:1] [con:0(guest@/127.0.0.1:52328/default)/ch:1] CHN-1003 : Close
2016-10-18 15:01:44,750 INFO  [IO-/127.0.0.1:52328] (q.m.c.create) - [con:0(guest@/127.0.0.1:52328/default)/ch:2] CHN-1001 : Create
2016-10-18 15:01:44,764 INFO  [IO-/127.0.0.1:52328] (q.m.c.prefetch_size) - [con:0(guest@/127.0.0.1:52328/default)/ch:2] CHN-1004 : Prefetch Size (bytes) 0 : Count 500
2016-10-18 15:01:44,792 INFO  [IO-/127.0.0.1:52331] (q.m.c.open) - [con:1(/127.0.0.1:52331)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9
2016-10-18 15:01:44,971 INFO  [IO-/127.0.0.1:52331] (q.m.c.open) - [con:1(guest@/127.0.0.1:52331/default)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9 : Client ID : clientid : Client Version : 6.1.0-SNAPSHOT : Client Product : qpid
2016-10-18 15:01:44,976 INFO  [IO-/127.0.0.1:52331] (q.m.c.create) - [con:1(guest@/127.0.0.1:52331/default)/ch:1] CHN-1001 : Create
2016-10-18 15:01:44,983 INFO  [IO-/127.0.0.1:52331] (q.m.c.prefetch_size) - [con:1(guest@/127.0.0.1:52331/default)/ch:1] CHN-1004 : Prefetch Size (bytes) 0 : Count 3
2016-10-18 15:01:45,006 INFO  [IO-/127.0.0.1:52331] (q.m.c.flow) - [con:1(guest@/127.0.0.1:52331/default)/ch:1] [con:1(guest@/127.0.0.1:52331/default)/ch:1] CHN-1002 : Flow Stopped
2016-10-18 15:01:45,046 INFO  [IO-/127.0.0.1:52331] (q.m.c.flow) - [con:1(guest@/127.0.0.1:52331/default)/ch:1] [con:1(guest@/127.0.0.1:52331/default)/ch:1] CHN-1002 : Flow Started
2016-10-18 15:01:45,091 INFO  [IO-/127.0.0.1:52331] (q.m.c.close) - [con:1(guest@/127.0.0.1:52331/default)/ch:1] [con:1(guest@/127.0.0.1:52331/default)/ch:1] CHN-1003 : Close
2016-10-18 15:01:45,103 INFO  [IO-/127.0.0.1:52331] (q.m.c.create) - [con:1(guest@/127.0.0.1:52331/default)/ch:2] CHN-1001 : Create
2016-10-18 15:01:45,117 INFO  [IO-/127.0.0.1:52331] (q.m.c.prefetch_size) - [con:1(guest@/127.0.0.1:52331/default)/ch:2] CHN-1004 : Prefetch Size (bytes) 0 : Count 500
2016-10-18 15:01:45,136 INFO  [IO-/127.0.0.1:52332] (q.m.c.open) - [con:2(/127.0.0.1:52332)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9
2016-10-18 15:01:45,256 INFO  [IO-/127.0.0.1:52332] (q.m.c.open) - [con:2(guest@/127.0.0.1:52332/default)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9 : Client ID : clientid : Client Version : 6.1.0-SNAPSHOT : Client Product : qpid
2016-10-18 15:01:45,281 INFO  [IO-/127.0.0.1:52332] (q.m.c.create) - [con:2(guest@/127.0.0.1:52332/default)/ch:1] CHN-1001 : Create
2016-10-18 15:01:45,286 INFO  [IO-/127.0.0.1:52332] (q.m.c.prefetch_size) - [con:2(guest@/127.0.0.1:52332/default)/ch:1] CHN-1004 : Prefetch Size (bytes) 0 : Count 3
2016-10-18 15:01:45,292 INFO  [IO-/127.0.0.1:52332] (q.m.c.flow) - [con:2(guest@/127.0.0.1:52332/default)/ch:1] [con:2(guest@/127.0.0.1:52332/default)/ch:1] CHN-1002 : Flow Stopped
2016-10-18 15:01:45,297 INFO  [IO-/127.0.0.1:52332] (q.m.c.flow) - [con:2(guest@/127.0.0.1:52332/default)/ch:1] [con:2(guest@/127.0.0.1:52332/default)/ch:1] CHN-1002 : Flow Started
2016-10-18 15:01:45,316 INFO  [IO-/127.0.0.1:52332] (q.m.c.close) - [con:2(guest@/127.0.0.1:52332/default)/ch:1] [con:2(guest@/127.0.0.1:52332/default)/ch:1] CHN-1003 : Close
2016-10-18 15:01:45,319 INFO  [IO-/127.0.0.1:52332] (q.m.c.create) - [con:2(guest@/127.0.0.1:52332/default)/ch:2] CHN-1001 : Create
2016-10-18 15:01:45,326 INFO  [IO-/127.0.0.1:52332] (q.m.c.prefetch_size) - [con:2(guest@/127.0.0.1:52332/default)/ch:2] CHN-1004 : Prefetch Size (bytes) 0 : Count 500
2016-10-18 15:01:45,377 INFO  [IO-/127.0.0.1:52334] (q.m.c.open) - [con:3(/127.0.0.1:52334)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9
2016-10-18 15:01:45,459 INFO  [IO-/127.0.0.1:52334] (q.m.c.open) - [con:3(guest@/127.0.0.1:52334/default)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9 : Client ID : clientid : Client Version : 6.1.0-SNAPSHOT : Client Product : qpid
2016-10-18 15:01:45,473 INFO  [IO-/127.0.0.1:52334] (q.m.c.create) - [con:3(guest@/127.0.0.1:52334/default)/ch:1] CHN-1001 : Create
2016-10-18 15:01:45,479 INFO  [IO-/127.0.0.1:52334] (q.m.c.prefetch_size) - [con:3(guest@/127.0.0.1:52334/default)/ch:1] CHN-1004 : Prefetch Size (bytes) 0 : Count 3
2016-10-18 15:01:45,485 INFO  [IO-/127.0.0.1:52334] (q.m.c.flow) - [con:3(guest@/127.0.0.1:52334/default)/ch:1] [con:3(guest@/127.0.0.1:52334/default)/ch:1] CHN-1002 : Flow Stopped
2016-10-18 15:01:45,491 INFO  [IO-/127.0.0.1:52334] (q.m.c.flow) - [con:3(guest@/127.0.0.1:52334/default)/ch:1] [con:3(guest@/127.0.0.1:52334/default)/ch:1] CHN-1002 : Flow Started
2016-10-18 15:01:45,507 INFO  [IO-/127.0.0.1:52334] (q.m.c.close) - [con:3(guest@/127.0.0.1:52334/default)/ch:1] [con:3(guest@/127.0.0.1:52334/default)/ch:1] CHN-1003 : Close
2016-10-18 15:01:45,511 INFO  [IO-/127.0.0.1:52334] (q.m.c.create) - [con:3(guest@/127.0.0.1:52334/default)/ch:2] CHN-1001 : Create
2016-10-18 15:01:45,518 INFO  [IO-/127.0.0.1:52334] (q.m.c.prefetch_size) - [con:3(guest@/127.0.0.1:52334/default)/ch:2] CHN-1004 : Prefetch Size (bytes) 0 : Count 500
2016-10-18 15:01:45,537 INFO  [IO-/127.0.0.1:52335] (q.m.c.open) - [con:4(/127.0.0.1:52335)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9
2016-10-18 15:01:45,676 INFO  [IO-/127.0.0.1:52335] (q.m.c.open) - [con:4(guest@/127.0.0.1:52335/default)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9 : Client ID : clientid : Client Version : 6.1.0-SNAPSHOT : Client Product : qpid
2016-10-18 15:01:45,683 INFO  [IO-/127.0.0.1:52335] (q.m.c.create) - [con:4(guest@/127.0.0.1:52335/default)/ch:1] CHN-1001 : Create
2016-10-18 15:01:45,692 INFO  [IO-/127.0.0.1:52335] (q.m.c.prefetch_size) - [con:4(guest@/127.0.0.1:52335/default)/ch:1] CHN-1004 : Prefetch Size (bytes) 0 : Count 3
2016-10-18 15:01:45,699 INFO  [IO-/127.0.0.1:52335] (q.m.c.flow) - [con:4(guest@/127.0.0.1:52335/default)/ch:1] [con:4(guest@/127.0.0.1:52335/default)/ch:1] CHN-1002 : Flow Stopped
2016-10-18 15:01:45,705 INFO  [IO-/127.0.0.1:52335] (q.m.c.flow) - [con:4(guest@/127.0.0.1:52335/default)/ch:1] [con:4(guest@/127.0.0.1:52335/default)/ch:1] CHN-1002 : Flow Started
2016-10-18 15:01:45,713 INFO  [IO-/127.0.0.1:52335] (q.m.c.close) - [con:4(guest@/127.0.0.1:52335/default)/ch:1] [con:4(guest@/127.0.0.1:52335/default)/ch:1] CHN-1003 : Close
2016-10-18 15:01:45,727 INFO  [IO-/127.0.0.1:52335] (q.m.c.create) - [con:4(guest@/127.0.0.1:52335/default)/ch:2] CHN-1001 : Create
2016-10-18 15:01:45,739 INFO  [IO-/127.0.0.1:52335] (q.m.c.prefetch_size) - [con:4(guest@/127.0.0.1:52335/default)/ch:2] CHN-1004 : Prefetch Size (bytes) 0 : Count 500
2016-10-18 15:01:45,755 INFO  [IO-/127.0.0.1:52336] (q.m.c.open) - [con:5(/127.0.0.1:52336)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9
2016-10-18 15:01:45,879 INFO  [IO-/127.0.0.1:52336] (q.m.c.open) - [con:5(guest@/127.0.0.1:52336/default)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9 : Client ID : clientid : Client Version : 6.1.0-SNAPSHOT : Client Product : qpid
2016-10-18 15:01:45,889 INFO  [IO-/127.0.0.1:52336] (q.m.c.create) - [con:5(guest@/127.0.0.1:52336/default)/ch:1] CHN-1001 : Create
2016-10-18 15:01:45,899 INFO  [IO-/127.0.0.1:52336] (q.m.c.prefetch_size) - [con:5(guest@/127.0.0.1:52336/default)/ch:1] CHN-1004 : Prefetch Size (bytes) 0 : Count 3
2016-10-18 15:01:45,907 INFO  [IO-/127.0.0.1:52336] (q.m.c.flow) - [con:5(guest@/127.0.0.1:52336/default)/ch:1] [con:5(guest@/127.0.0.1:52336/default)/ch:1] CHN-1002 : Flow Stopped
2016-10-18 15:01:45,912 INFO  [IO-/127.0.0.1:52336] (q.m.c.flow) - [con:5(guest@/127.0.0.1:52336/default)/ch:1] [con:5(guest@/127.0.0.1:52336/default)/ch:1] CHN-1002 : Flow Started
2016-10-18 15:01:45,938 INFO  [IO-/127.0.0.1:52336] (q.m.c.close) - [con:5(guest@/127.0.0.1:52336/default)/ch:1] [con:5(guest@/127.0.0.1:52336/default)/ch:1] CHN-1003 : Close
2016-10-18 15:01:45,942 INFO  [IO-/127.0.0.1:52336] (q.m.c.create) - [con:5(guest@/127.0.0.1:52336/default)/ch:2] CHN-1001 : Create
2016-10-18 15:01:45,956 INFO  [IO-/127.0.0.1:52336] (q.m.c.prefetch_size) - [con:5(guest@/127.0.0.1:52336/default)/ch:2] CHN-1004 : Prefetch Size (bytes) 0 : Count 500
2016-10-18 15:01:45,980 INFO  [IO-/127.0.0.1:52337] (q.m.c.open) - [con:6(/127.0.0.1:52337)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9
2016-10-18 15:01:46,087 INFO  [IO-/127.0.0.1:52337] (q.m.c.open) - [con:6(guest@/127.0.0.1:52337/default)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9 : Client ID : clientid : Client Version : 6.1.0-SNAPSHOT : Client Product : qpid
2016-10-18 15:01:46,091 INFO  [IO-/127.0.0.1:52337] (q.m.c.create) - [con:6(guest@/127.0.0.1:52337/default)/ch:1] CHN-1001 : Create
2016-10-18 15:01:46,100 INFO  [IO-/127.0.0.1:52337] (q.m.c.prefetch_size) - [con:6(guest@/127.0.0.1:52337/default)/ch:1] CHN-1004 : Prefetch Size (bytes) 0 : Count 3
2016-10-18 15:01:46,110 INFO  [IO-/127.0.0.1:52337] (q.m.c.flow) - [con:6(guest@/127.0.0.1:52337/default)/ch:1] [con:6(guest@/127.0.0.1:52337/default)/ch:1] CHN-1002 : Flow Stopped
2016-10-18 15:01:46,119 INFO  [IO-/127.0.0.1:52337] (q.m.c.flow) - [con:6(guest@/127.0.0.1:52337/default)/ch:1] [con:6(guest@/127.0.0.1:52337/default)/ch:1] CHN-1002 : Flow Started
2016-10-18 15:01:46,134 INFO  [IO-/127.0.0.1:52337] (q.m.c.close) - [con:6(guest@/127.0.0.1:52337/default)/ch:1] [con:6(guest@/127.0.0.1:52337/default)/ch:1] CHN-1003 : Close
2016-10-18 15:01:46,142 INFO  [IO-/127.0.0.1:52337] (q.m.c.create) - [con:6(guest@/127.0.0.1:52337/default)/ch:2] CHN-1001 : Create
2016-10-18 15:01:46,157 INFO  [IO-/127.0.0.1:52337] (q.m.c.prefetch_size) - [con:6(guest@/127.0.0.1:52337/default)/ch:2] CHN-1004 : Prefetch Size (bytes) 0 : Count 500
2016-10-18 15:01:46,175 INFO  [IO-/127.0.0.1:52338] (q.m.c.open) - [con:7(/127.0.0.1:52338)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9
2016-10-18 15:01:46,295 INFO  [IO-/127.0.0.1:52338] (q.m.c.open) - [con:7(guest@/127.0.0.1:52338/default)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9 : Client ID : clientid : Client Version : 6.1.0-SNAPSHOT : Client Product : qpid
2016-10-18 15:01:46,305 INFO  [IO-/127.0.0.1:52338] (q.m.c.create) - [con:7(guest@/127.0.0.1:52338/default)/ch:1] CHN-1001 : Create
2016-10-18 15:01:46,315 INFO  [IO-/127.0.0.1:52338] (q.m.c.prefetch_size) - [con:7(guest@/127.0.0.1:52338/default)/ch:1] CHN-1004 : Prefetch Size (bytes) 0 : Count 3
2016-10-18 15:01:46,326 INFO  [IO-/127.0.0.1:52338] (q.m.c.flow) - [con:7(guest@/127.0.0.1:52338/default)/ch:1] [con:7(guest@/127.0.0.1:52338/default)/ch:1] CHN-1002 : Flow Stopped
2016-10-18 15:01:46,333 INFO  [IO-/127.0.0.1:52338] (q.m.c.flow) - [con:7(guest@/127.0.0.1:52338/default)/ch:1] [con:7(guest@/127.0.0.1:52338/default)/ch:1] CHN-1002 : Flow Started
2016-10-18 15:01:46,355 INFO  [IO-/127.0.0.1:52338] (q.m.c.close) - [con:7(guest@/127.0.0.1:52338/default)/ch:1] [con:7(guest@/127.0.0.1:52338/default)/ch:1] CHN-1003 : Close
2016-10-18 15:01:46,358 INFO  [IO-/127.0.0.1:52338] (q.m.c.create) - [con:7(guest@/127.0.0.1:52338/default)/ch:2] CHN-1001 : Create
2016-10-18 15:01:46,373 INFO  [IO-/127.0.0.1:52338] (q.m.c.prefetch_size) - [con:7(guest@/127.0.0.1:52338/default)/ch:2] CHN-1004 : Prefetch Size (bytes) 0 : Count 500
2016-10-18 15:01:46,476 INFO  [IO-/127.0.0.1:52339] (q.m.c.open) - [con:8(/127.0.0.1:52339)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9
2016-10-18 15:01:46,637 INFO  [IO-/127.0.0.1:52339] (q.m.c.open) - [con:8(guest@/127.0.0.1:52339/default)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9 : Client ID : clientid : Client Version : 6.1.0-SNAPSHOT : Client Product : qpid
2016-10-18 15:01:46,641 INFO  [IO-/127.0.0.1:52339] (q.m.c.create) - [con:8(guest@/127.0.0.1:52339/default)/ch:1] CHN-1001 : Create
2016-10-18 15:01:46,645 INFO  [IO-/127.0.0.1:52339] (q.m.c.prefetch_size) - [con:8(guest@/127.0.0.1:52339/default)/ch:1] CHN-1004 : Prefetch Size (bytes) 0 : Count 3
2016-10-18 15:01:46,651 INFO  [IO-/127.0.0.1:52339] (q.m.c.flow) - [con:8(guest@/127.0.0.1:52339/default)/ch:1] [con:8(guest@/127.0.0.1:52339/default)/ch:1] CHN-1002 : Flow Stopped
2016-10-18 15:01:46,656 INFO  [IO-/127.0.0.1:52339] (q.m.c.flow) - [con:8(guest@/127.0.0.1:52339/default)/ch:1] [con:8(guest@/127.0.0.1:52339/default)/ch:1] CHN-1002 : Flow Started
2016-10-18 15:01:46,679 INFO  [IO-/127.0.0.1:52339] (q.m.c.close) - [con:8(guest@/127.0.0.1:52339/default)/ch:1] [con:8(guest@/127.0.0.1:52339/default)/ch:1] CHN-1003 : Close
2016-10-18 15:01:46,686 INFO  [IO-/127.0.0.1:52339] (q.m.c.create) - [con:8(guest@/127.0.0.1:52339/default)/ch:2] CHN-1001 : Create
2016-10-18 15:01:46,695 INFO  [IO-/127.0.0.1:52339] (q.m.c.prefetch_size) - [con:8(guest@/127.0.0.1:52339/default)/ch:2] CHN-1004 : Prefetch Size (bytes) 0 : Count 500
2016-10-18 15:01:46,716 INFO  [IO-/127.0.0.1:52341] (q.m.c.open) - [con:9(/127.0.0.1:52341)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9
2016-10-18 15:01:46,842 INFO  [IO-/127.0.0.1:52341] (q.m.c.open) - [con:9(guest@/127.0.0.1:52341/default)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9 : Client ID : clientid : Client Version : 6.1.0-SNAPSHOT : Client Product : qpid
2016-10-18 15:01:46,846 INFO  [IO-/127.0.0.1:52341] (q.m.c.create) - [con:9(guest@/127.0.0.1:52341/default)/ch:1] CHN-1001 : Create
2016-10-18 15:01:46,854 INFO  [IO-/127.0.0.1:52341] (q.m.c.prefetch_size) - [con:9(guest@/127.0.0.1:52341/default)/ch:1] CHN-1004 : Prefetch Size (bytes) 0 : Count 3
2016-10-18 15:01:46,863 INFO  [IO-/127.0.0.1:52341] (q.m.c.flow) - [con:9(guest@/127.0.0.1:52341/default)/ch:1] [con:9(guest@/127.0.0.1:52341/default)/ch:1] CHN-1002 : Flow Stopped
2016-10-18 15:01:46,874 INFO  [IO-/127.0.0.1:52341] (q.m.c.flow) - [con:9(guest@/127.0.0.1:52341/default)/ch:1] [con:9(guest@/127.0.0.1:52341/default)/ch:1] CHN-1002 : Flow Started
2016-10-18 15:01:46,892 INFO  [IO-/127.0.0.1:52341] (q.m.c.close) - [con:9(guest@/127.0.0.1:52341/default)/ch:1] [con:9(guest@/127.0.0.1:52341/default)/ch:1] CHN-1003 : Close
2016-10-18 15:01:46,899 INFO  [IO-/127.0.0.1:52341] (q.m.c.create) - [con:9(guest@/127.0.0.1:52341/default)/ch:2] CHN-1001 : Create
2016-10-18 15:01:46,915 INFO  [IO-/127.0.0.1:52341] (q.m.c.prefetch_size) - [con:9(guest@/127.0.0.1:52341/default)/ch:2] CHN-1004 : Prefetch Size (bytes) 0 : Count 500
2016-10-18 15:01:46,936 INFO  [IO-/127.0.0.1:52342] (q.m.c.open) - [con:10(/127.0.0.1:52342)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9
2016-10-18 15:01:47,055 INFO  [IO-/127.0.0.1:52342] (q.m.c.open) - [con:10(guest@/127.0.0.1:52342/default)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9 : Client ID : clientid : Client Version : 6.1.0-SNAPSHOT : Client Product : qpid
2016-10-18 15:01:47,057 INFO  [IO-/127.0.0.1:52342] (q.m.c.create) - [con:10(guest@/127.0.0.1:52342/default)/ch:1] CHN-1001 : Create
2016-10-18 15:01:47,064 INFO  [IO-/127.0.0.1:52342] (q.m.c.prefetch_size) - [con:10(guest@/127.0.0.1:52342/default)/ch:1] CHN-1004 : Prefetch Size (bytes) 0 : Count 3
2016-10-18 15:01:47,079 INFO  [IO-/127.0.0.1:52342] (q.m.c.flow) - [con:10(guest@/127.0.0.1:52342/default)/ch:1] [con:10(guest@/127.0.0.1:52342/default)/ch:1] CHN-1002 : Flow Stopped
2016-10-18 15:01:47,087 INFO  [IO-/127.0.0.1:52342] (q.m.c.flow) - [con:10(guest@/127.0.0.1:52342/default)/ch:1] [con:10(guest@/127.0.0.1:52342/default)/ch:1] CHN-1002 : Flow Started
2016-10-18 15:01:47,119 INFO  [IO-/127.0.0.1:52342] (q.m.c.close) - [con:10(guest@/127.0.0.1:52342/default)/ch:1] [con:10(guest@/127.0.0.1:52342/default)/ch:1] CHN-1003 : Close
2016-10-18 15:01:47,123 INFO  [IO-/127.0.0.1:52342] (q.m.c.create) - [con:10(guest@/127.0.0.1:52342/default)/ch:2] CHN-1001 : Create
2016-10-18 15:01:47,133 INFO  [IO-/127.0.0.1:52342] (q.m.c.prefetch_size) - [con:10(guest@/127.0.0.1:52342/default)/ch:2] CHN-1004 : Prefetch Size (bytes) 0 : Count 500
2016-10-18 15:01:47,158 INFO  [IO-/127.0.0.1:52343] (q.m.c.open) - [con:11(/127.0.0.1:52343)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9
2016-10-18 15:01:47,378 INFO  [IO-/127.0.0.1:52343] (q.m.c.open) - [con:11(guest@/127.0.0.1:52343/default)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9 : Client ID : clientid : Client Version : 6.1.0-SNAPSHOT : Client Product : qpid
2016-10-18 15:01:47,381 INFO  [IO-/127.0.0.1:52343] (q.m.c.create) - [con:11(guest@/127.0.0.1:52343/default)/ch:1] CHN-1001 : Create
2016-10-18 15:01:47,385 INFO  [IO-/127.0.0.1:52343] (q.m.c.prefetch_size) - [con:11(guest@/127.0.0.1:52343/default)/ch:1] CHN-1004 : Prefetch Size (bytes) 0 : Count 3
2016-10-18 15:01:47,389 INFO  [IO-/127.0.0.1:52343] (q.m.c.flow) - [con:11(guest@/127.0.0.1:52343/default)/ch:1] [con:11(guest@/127.0.0.1:52343/default)/ch:1] CHN-1002 : Flow Stopped
2016-10-18 15:01:47,399 INFO  [IO-/127.0.0.1:52343] (q.m.c.flow) - [con:11(guest@/127.0.0.1:52343/default)/ch:1] [con:11(guest@/127.0.0.1:52343/default)/ch:1] CHN-1002 : Flow Started
2016-10-18 15:01:47,418 INFO  [IO-/127.0.0.1:52343] (q.m.c.close) - [con:11(guest@/127.0.0.1:52343/default)/ch:1] [con:11(guest@/127.0.0.1:52343/default)/ch:1] CHN-1003 : Close
2016-10-18 15:01:47,423 INFO  [IO-/127.0.0.1:52343] (q.m.c.create) - [con:11(guest@/127.0.0.1:52343/default)/ch:2] CHN-1001 : Create
2016-10-18 15:01:47,435 INFO  [IO-/127.0.0.1:52343] (q.m.c.prefetch_size) - [con:11(guest@/127.0.0.1:52343/default)/ch:2] CHN-1004 : Prefetch Size (bytes) 0 : Count 500
2016-10-18 15:01:47,449 INFO  [IO-/127.0.0.1:52344] (q.m.c.open) - [con:12(/127.0.0.1:52344)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9
2016-10-18 15:01:47,560 INFO  [IO-/127.0.0.1:52344] (q.m.c.open) - [con:12(guest@/127.0.0.1:52344/default)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9 : Client ID : clientid : Client Version : 6.1.0-SNAPSHOT : Client Product : qpid
2016-10-18 15:01:47,564 INFO  [IO-/127.0.0.1:52344] (q.m.c.create) - [con:12(guest@/127.0.0.1:52344/default)/ch:1] CHN-1001 : Create
2016-10-18 15:01:47,570 INFO  [IO-/127.0.0.1:52344] (q.m.c.prefetch_size) - [con:12(guest@/127.0.0.1:52344/default)/ch:1] CHN-1004 : Prefetch Size (bytes) 0 : Count 3
2016-10-18 15:01:47,581 INFO  [IO-/127.0.0.1:52344] (q.m.c.flow) - [con:12(guest@/127.0.0.1:52344/default)/ch:1] [con:12(guest@/127.0.0.1:52344/default)/ch:1] CHN-1002 : Flow Stopped
2016-10-18 15:01:47,588 INFO  [IO-/127.0.0.1:52344] (q.m.c.flow) - [con:12(guest@/127.0.0.1:52344/default)/ch:1] [con:12(guest@/127.0.0.1:52344/default)/ch:1] CHN-1002 : Flow Started
2016-10-18 15:01:47,610 INFO  [IO-/127.0.0.1:52344] (q.m.c.close) - [con:12(guest@/127.0.0.1:52344/default)/ch:1] [con:12(guest@/127.0.0.1:52344/default)/ch:1] CHN-1003 : Close
2016-10-18 15:01:47,618 INFO  [IO-/127.0.0.1:52344] (q.m.c.create) - [con:12(guest@/127.0.0.1:52344/default)/ch:2] CHN-1001 : Create
2016-10-18 15:01:47,623 INFO  [IO-/127.0.0.1:52344] (q.m.c.prefetch_size) - [con:12(guest@/127.0.0.1:52344/default)/ch:2] CHN-1004 : Prefetch Size (bytes) 0 : Count 500
2016-10-18 15:01:47,640 INFO  [IO-/127.0.0.1:52345] (q.m.c.open) - [con:13(/127.0.0.1:52345)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9
2016-10-18 15:01:47,762 INFO  [IO-/127.0.0.1:52345] (q.m.c.open) - [con:13(guest@/127.0.0.1:52345/default)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9 : Client ID : clientid : Client Version : 6.1.0-SNAPSHOT : Client Product : qpid
2016-10-18 15:01:47,770 INFO  [IO-/127.0.0.1:52345] (q.m.c.create) - [con:13(guest@/127.0.0.1:52345/default)/ch:1] CHN-1001 : Create
2016-10-18 15:01:47,776 INFO  [IO-/127.0.0.1:52345] (q.m.c.prefetch_size) - [con:13(guest@/127.0.0.1:52345/default)/ch:1] CHN-1004 : Prefetch Size (bytes) 0 : Count 3
2016-10-18 15:01:47,782 INFO  [IO-/127.0.0.1:52345] (q.m.c.flow) - [con:13(guest@/127.0.0.1:52345/default)/ch:1] [con:13(guest@/127.0.0.1:52345/default)/ch:1] CHN-1002 : Flow Stopped
2016-10-18 15:01:47,786 INFO  [IO-/127.0.0.1:52345] (q.m.c.flow) - [con:13(guest@/127.0.0.1:52345/default)/ch:1] [con:13(guest@/127.0.0.1:52345/default)/ch:1] CHN-1002 : Flow Started
2016-10-18 15:01:47,795 INFO  [IO-/127.0.0.1:52345] (q.m.c.close) - [con:13(guest@/127.0.0.1:52345/default)/ch:1] [con:13(guest@/127.0.0.1:52345/default)/ch:1] CHN-1003 : Close
2016-10-18 15:01:47,799 INFO  [IO-/127.0.0.1:52345] (q.m.c.create) - [con:13(guest@/127.0.0.1:52345/default)/ch:2] CHN-1001 : Create
2016-10-18 15:01:47,807 INFO  [IO-/127.0.0.1:52345] (q.m.c.prefetch_size) - [con:13(guest@/127.0.0.1:52345/default)/ch:2] CHN-1004 : Prefetch Size (bytes) 0 : Count 500
2016-10-18 15:01:47,823 INFO  [IO-/127.0.0.1:52346] (q.m.c.open) - [con:14(/127.0.0.1:52346)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9
2016-10-18 15:01:47,893 INFO  [IO-/127.0.0.1:52346] (q.m.c.open) - [con:14(guest@/127.0.0.1:52346/default)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9 : Client ID : clientid : Client Version : 6.1.0-SNAPSHOT : Client Product : qpid
2016-10-18 15:01:47,897 INFO  [IO-/127.0.0.1:52346] (q.m.c.create) - [con:14(guest@/127.0.0.1:52346/default)/ch:1] CHN-1001 : Create
2016-10-18 15:01:47,904 INFO  [IO-/127.0.0.1:52346] (q.m.c.prefetch_size) - [con:14(guest@/127.0.0.1:52346/default)/ch:1] CHN-1004 : Prefetch Size (bytes) 0 : Count 3
2016-10-18 15:01:47,906 INFO  [IO-/127.0.0.1:52346] (q.m.c.flow) - [con:14(guest@/127.0.0.1:52346/default)/ch:1] [con:14(guest@/127.0.0.1:52346/default)/ch:1] CHN-1002 : Flow Stopped
2016-10-18 15:01:47,912 INFO  [IO-/127.0.0.1:52346] (q.m.c.flow) - [con:14(guest@/127.0.0.1:52346/default)/ch:1] [con:14(guest@/127.0.0.1:52346/default)/ch:1] CHN-1002 : Flow Started
2016-10-18 15:01:47,925 INFO  [IO-/127.0.0.1:52346] (q.m.c.close) - [con:14(guest@/127.0.0.1:52346/default)/ch:1] [con:14(guest@/127.0.0.1:52346/default)/ch:1] CHN-1003 : Close
2016-10-18 15:01:47,931 INFO  [IO-/127.0.0.1:52346] (q.m.c.create) - [con:14(guest@/127.0.0.1:52346/default)/ch:2] CHN-1001 : Create
2016-10-18 15:01:47,939 INFO  [IO-/127.0.0.1:52346] (q.m.c.prefetch_size) - [con:14(guest@/127.0.0.1:52346/default)/ch:2] CHN-1004 : Prefetch Size (bytes) 0 : Count 500
2016-10-18 15:01:47,967 INFO  [IO-/127.0.0.1:52347] (q.m.c.open) - [con:15(/127.0.0.1:52347)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9
2016-10-18 15:01:48,059 INFO  [IO-/127.0.0.1:52347] (q.m.c.open) - [con:15(guest@/127.0.0.1:52347/default)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9 : Client ID : clientid : Client Version : 6.1.0-SNAPSHOT : Client Product : qpid
2016-10-18 15:01:48,063 INFO  [IO-/127.0.0.1:52347] (q.m.c.create) - [con:15(guest@/127.0.0.1:52347/default)/ch:1] CHN-1001 : Create
2016-10-18 15:01:48,067 INFO  [IO-/127.0.0.1:52347] (q.m.c.prefetch_size) - [con:15(guest@/127.0.0.1:52347/default)/ch:1] CHN-1004 : Prefetch Size (bytes) 0 : Count 3
2016-10-18 15:01:48,076 INFO  [IO-/127.0.0.1:52347] (q.m.c.flow) - [con:15(guest@/127.0.0.1:52347/default)/ch:1] [con:15(guest@/127.0.0.1:52347/default)/ch:1] CHN-1002 : Flow Stopped
2016-10-18 15:01:48,080 INFO  [IO-/127.0.0.1:52347] (q.m.c.flow) - [con:15(guest@/127.0.0.1:52347/default)/ch:1] [con:15(guest@/127.0.0.1:52347/default)/ch:1] CHN-1002 : Flow Started
2016-10-18 15:01:48,093 INFO  [IO-/127.0.0.1:52347] (q.m.c.close) - [con:15(guest@/127.0.0.1:52347/default)/ch:1] [con:15(guest@/127.0.0.1:52347/default)/ch:1] CHN-1003 : Close
2016-10-18 15:01:48,095 INFO  [IO-/127.0.0.1:52347] (q.m.c.create) - [con:15(guest@/127.0.0.1:52347/default)/ch:2] CHN-1001 : Create
2016-10-18 15:01:48,101 INFO  [IO-/127.0.0.1:52347] (q.m.c.prefetch_size) - [con:15(guest@/127.0.0.1:52347/default)/ch:2] CHN-1004 : Prefetch Size (bytes) 0 : Count 500
2016-10-18 15:01:48,120 INFO  [IO-/127.0.0.1:52348] (q.m.c.open) - [con:16(/127.0.0.1:52348)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9
2016-10-18 15:01:48,235 INFO  [IO-/127.0.0.1:52348] (q.m.c.open) - [con:16(guest@/127.0.0.1:52348/default)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9 : Client ID : clientid : Client Version : 6.1.0-SNAPSHOT : Client Product : qpid
2016-10-18 15:01:48,258 INFO  [IO-/127.0.0.1:52348] (q.m.c.create) - [con:16(guest@/127.0.0.1:52348/default)/ch:1] CHN-1001 : Create
2016-10-18 15:01:48,287 INFO  [IO-/127.0.0.1:52348] (q.m.c.prefetch_size) - [con:16(guest@/127.0.0.1:52348/default)/ch:1] CHN-1004 : Prefetch Size (bytes) 0 : Count 3
2016-10-18 15:01:48,292 INFO  [IO-/127.0.0.1:52348] (q.m.c.flow) - [con:16(guest@/127.0.0.1:52348/default)/ch:1] [con:16(guest@/127.0.0.1:52348/default)/ch:1] CHN-1002 : Flow Stopped
2016-10-18 15:01:48,298 INFO  [IO-/127.0.0.1:52348] (q.m.c.flow) - [con:16(guest@/127.0.0.1:52348/default)/ch:1] [con:16(guest@/127.0.0.1:52348/default)/ch:1] CHN-1002 : Flow Started
2016-10-18 15:01:48,327 INFO  [IO-/127.0.0.1:52348] (q.m.c.close) - [con:16(guest@/127.0.0.1:52348/default)/ch:1] [con:16(guest@/127.0.0.1:52348/default)/ch:1] CHN-1003 : Close
2016-10-18 15:01:48,330 INFO  [IO-/127.0.0.1:52348] (q.m.c.create) - [con:16(guest@/127.0.0.1:52348/default)/ch:2] CHN-1001 : Create
2016-10-18 15:01:48,339 INFO  [IO-/127.0.0.1:52348] (q.m.c.prefetch_size) - [con:16(guest@/127.0.0.1:52348/default)/ch:2] CHN-1004 : Prefetch Size (bytes) 0 : Count 500
2016-10-18 15:01:48,352 INFO  [IO-/127.0.0.1:52349] (q.m.c.open) - [con:17(/127.0.0.1:52349)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9
2016-10-18 15:01:48,463 INFO  [IO-/127.0.0.1:52349] (q.m.c.open) - [con:17(guest@/127.0.0.1:52349/default)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9 : Client ID : clientid : Client Version : 6.1.0-SNAPSHOT : Client Product : qpid
2016-10-18 15:01:48,467 INFO  [IO-/127.0.0.1:52349] (q.m.c.create) - [con:17(guest@/127.0.0.1:52349/default)/ch:1] CHN-1001 : Create
2016-10-18 15:01:48,472 INFO  [IO-/127.0.0.1:52349] (q.m.c.prefetch_size) - [con:17(guest@/127.0.0.1:52349/default)/ch:1] CHN-1004 : Prefetch Size (bytes) 0 : Count 3
2016-10-18 15:01:48,481 INFO  [IO-/127.0.0.1:52349] (q.m.c.flow) - [con:17(guest@/127.0.0.1:52349/default)/ch:1] [con:17(guest@/127.0.0.1:52349/default)/ch:1] CHN-1002 : Flow Stopped
2016-10-18 15:01:48,491 INFO  [IO-/127.0.0.1:52349] (q.m.c.flow) - [con:17(guest@/127.0.0.1:52349/default)/ch:1] [con:17(guest@/127.0.0.1:52349/default)/ch:1] CHN-1002 : Flow Started
2016-10-18 15:01:48,511 INFO  [IO-/127.0.0.1:52349] (q.m.c.close) - [con:17(guest@/127.0.0.1:52349/default)/ch:1] [con:17(guest@/127.0.0.1:52349/default)/ch:1] CHN-1003 : Close
2016-10-18 15:01:48,515 INFO  [IO-/127.0.0.1:52349] (q.m.c.create) - [con:17(guest@/127.0.0.1:52349/default)/ch:2] CHN-1001 : Create
2016-10-18 15:01:48,524 INFO  [IO-/127.0.0.1:52349] (q.m.c.prefetch_size) - [con:17(guest@/127.0.0.1:52349/default)/ch:2] CHN-1004 : Prefetch Size (bytes) 0 : Count 500
2016-10-18 15:01:48,537 INFO  [IO-/127.0.0.1:52350] (q.m.c.open) - [con:18(/127.0.0.1:52350)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9
2016-10-18 15:01:48,597 INFO  [IO-/127.0.0.1:52350] (q.m.c.open) - [con:18(guest@/127.0.0.1:52350/default)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9 : Client ID : clientid : Client Version : 6.1.0-SNAPSHOT : Client Product : qpid
2016-10-18 15:01:48,600 INFO  [IO-/127.0.0.1:52350] (q.m.c.create) - [con:18(guest@/127.0.0.1:52350/default)/ch:1] CHN-1001 : Create
2016-10-18 15:01:48,606 INFO  [IO-/127.0.0.1:52350] (q.m.c.prefetch_size) - [con:18(guest@/127.0.0.1:52350/default)/ch:1] CHN-1004 : Prefetch Size (bytes) 0 : Count 3
2016-10-18 15:01:48,610 INFO  [IO-/127.0.0.1:52350] (q.m.c.flow) - [con:18(guest@/127.0.0.1:52350/default)/ch:1] [con:18(guest@/127.0.0.1:52350/default)/ch:1] CHN-1002 : Flow Stopped
2016-10-18 15:01:48,615 INFO  [IO-/127.0.0.1:52350] (q.m.c.flow) - [con:18(guest@/127.0.0.1:52350/default)/ch:1] [con:18(guest@/127.0.0.1:52350/default)/ch:1] CHN-1002 : Flow Started
2016-10-18 15:01:48,625 INFO  [IO-/127.0.0.1:52350] (q.m.c.close) - [con:18(guest@/127.0.0.1:52350/default)/ch:1] [con:18(guest@/127.0.0.1:52350/default)/ch:1] CHN-1003 : Close
2016-10-18 15:01:48,627 INFO  [IO-/127.0.0.1:52350] (q.m.c.create) - [con:18(guest@/127.0.0.1:52350/default)/ch:2] CHN-1001 : Create
2016-10-18 15:01:48,630 INFO  [IO-/127.0.0.1:52350] (q.m.c.prefetch_size) - [con:18(guest@/127.0.0.1:52350/default)/ch:2] CHN-1004 : Prefetch Size (bytes) 0 : Count 500
2016-10-18 15:01:48,647 INFO  [IO-/127.0.0.1:52353] (q.m.c.open) - [con:19(/127.0.0.1:52353)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9
2016-10-18 15:01:48,704 INFO  [IO-/127.0.0.1:52353] (q.m.c.open) - [con:19(guest@/127.0.0.1:52353/default)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9 : Client ID : clientid : Client Version : 6.1.0-SNAPSHOT : Client Product : qpid
2016-10-18 15:01:48,707 INFO  [IO-/127.0.0.1:52353] (q.m.c.create) - [con:19(guest@/127.0.0.1:52353/default)/ch:1] CHN-1001 : Create
2016-10-18 15:01:48,716 INFO  [IO-/127.0.0.1:52353] (q.m.c.prefetch_size) - [con:19(guest@/127.0.0.1:52353/default)/ch:1] CHN-1004 : Prefetch Size (bytes) 0 : Count 3
2016-10-18 15:01:48,719 INFO  [IO-/127.0.0.1:52353] (q.m.c.flow) - [con:19(guest@/127.0.0.1:52353/default)/ch:1] [con:19(guest@/127.0.0.1:52353/default)/ch:1] CHN-1002 : Flow Stopped
2016-10-18 15:01:48,723 INFO  [IO-/127.0.0.1:52353] (q.m.c.flow) - [con:19(guest@/127.0.0.1:52353/default)/ch:1] [con:19(guest@/127.0.0.1:52353/default)/ch:1] CHN-1002 : Flow Started
2016-10-18 15:01:48,730 INFO  [IO-/127.0.0.1:52353] (q.m.c.close) - [con:19(guest@/127.0.0.1:52353/default)/ch:1] [con:19(guest@/127.0.0.1:52353/default)/ch:1] CHN-1003 : Close
2016-10-18 15:01:48,732 INFO  [IO-/127.0.0.1:52353] (q.m.c.create) - [con:19(guest@/127.0.0.1:52353/default)/ch:2] CHN-1001 : Create
2016-10-18 15:01:48,737 INFO  [IO-/127.0.0.1:52353] (q.m.c.prefetch_size) - [con:19(guest@/127.0.0.1:52353/default)/ch:2] CHN-1004 : Prefetch Size (bytes) 0 : Count 500
2016-10-18 15:01:48,743 INFO  [IO-/127.0.0.1:52354] (q.m.c.open) - [con:20(/127.0.0.1:52354)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9
2016-10-18 15:01:48,797 INFO  [IO-/127.0.0.1:52354] (q.m.c.open) - [con:20(guest@/127.0.0.1:52354/default)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9 : Client ID : clientid : Client Version : 6.1.0-SNAPSHOT : Client Product : qpid
2016-10-18 15:01:48,803 INFO  [IO-/127.0.0.1:52354] (q.m.c.create) - [con:20(guest@/127.0.0.1:52354/default)/ch:1] CHN-1001 : Create
2016-10-18 15:01:48,806 INFO  [IO-/127.0.0.1:52354] (q.m.c.prefetch_size) - [con:20(guest@/127.0.0.1:52354/default)/ch:1] CHN-1004 : Prefetch Size (bytes) 0 : Count 3
2016-10-18 15:01:48,820 INFO  [IO-/127.0.0.1:52354] (q.m.c.flow) - [con:20(guest@/127.0.0.1:52354/default)/ch:1] [con:20(guest@/127.0.0.1:52354/default)/ch:1] CHN-1002 : Flow Stopped
2016-10-18 15:01:48,823 INFO  [IO-/127.0.0.1:52354] (q.m.c.flow) - [con:20(guest@/127.0.0.1:52354/default)/ch:1] [con:20(guest@/127.0.0.1:52354/default)/ch:1] CHN-1002 : Flow Started
2016-10-18 15:01:48,833 INFO  [IO-/127.0.0.1:52354] (q.m.c.close) - [con:20(guest@/127.0.0.1:52354/default)/ch:1] [con:20(guest@/127.0.0.1:52354/default)/ch:1] CHN-1003 : Close
2016-10-18 15:01:48,836 INFO  [IO-/127.0.0.1:52354] (q.m.c.create) - [con:20(guest@/127.0.0.1:52354/default)/ch:2] CHN-1001 : Create
2016-10-18 15:01:48,843 INFO  [IO-/127.0.0.1:52354] (q.m.c.prefetch_size) - [con:20(guest@/127.0.0.1:52354/default)/ch:2] CHN-1004 : Prefetch Size (bytes) 0 : Count 500
2016-10-18 15:01:48,867 INFO  [IO-/127.0.0.1:52355] (q.m.c.open) - [con:21(/127.0.0.1:52355)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9
2016-10-18 15:01:49,003 INFO  [IO-/127.0.0.1:52355] (q.m.c.open) - [con:21(guest@/127.0.0.1:52355/default)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9 : Client ID : clientid : Client Version : 6.1.0-SNAPSHOT : Client Product : qpid
2016-10-18 15:01:49,010 INFO  [IO-/127.0.0.1:52355] (q.m.c.create) - [con:21(guest@/127.0.0.1:52355/default)/ch:1] CHN-1001 : Create
2016-10-18 15:01:49,023 INFO  [IO-/127.0.0.1:52355] (q.m.c.prefetch_size) - [con:21(guest@/127.0.0.1:52355/default)/ch:1] CHN-1004 : Prefetch Size (bytes) 0 : Count 3
2016-10-18 15:01:49,034 INFO  [IO-/127.0.0.1:52355] (q.m.c.flow) - [con:21(guest@/127.0.0.1:52355/default)/ch:1] [con:21(guest@/127.0.0.1:52355/default)/ch:1] CHN-1002 : Flow Stopped
2016-10-18 15:01:49,038 INFO  [IO-/127.0.0.1:52355] (q.m.c.flow) - [con:21(guest@/127.0.0.1:52355/default)/ch:1] [con:21(guest@/127.0.0.1:52355/default)/ch:1] CHN-1002 : Flow Started
2016-10-18 15:01:49,063 INFO  [IO-/127.0.0.1:52355] (q.m.c.close) - [con:21(guest@/127.0.0.1:52355/default)/ch:1] [con:21(guest@/127.0.0.1:52355/default)/ch:1] CHN-1003 : Close
2016-10-18 15:01:49,065 INFO  [IO-/127.0.0.1:52355] (q.m.c.create) - [con:21(guest@/127.0.0.1:52355/default)/ch:2] CHN-1001 : Create
2016-10-18 15:01:49,069 INFO  [IO-/127.0.0.1:52355] (q.m.c.prefetch_size) - [con:21(guest@/127.0.0.1:52355/default)/ch:2] CHN-1004 : Prefetch Size (bytes) 0 : Count 500
2016-10-18 15:01:49,078 INFO  [IO-/127.0.0.1:52356] (q.m.c.open) - [con:22(/127.0.0.1:52356)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9
2016-10-18 15:01:49,135 INFO  [IO-/127.0.0.1:52356] (q.m.c.open) - [con:22(guest@/127.0.0.1:52356/default)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9 : Client ID : clientid : Client Version : 6.1.0-SNAPSHOT : Client Product : qpid
2016-10-18 15:01:49,142 INFO  [IO-/127.0.0.1:52356] (q.m.c.create) - [con:22(guest@/127.0.0.1:52356/default)/ch:1] CHN-1001 : Create
2016-10-18 15:01:49,147 INFO  [IO-/127.0.0.1:52356] (q.m.c.prefetch_size) - [con:22(guest@/127.0.0.1:52356/default)/ch:1] CHN-1004 : Prefetch Size (bytes) 0 : Count 3
2016-10-18 15:01:49,159 INFO  [IO-/127.0.0.1:52356] (q.m.c.flow) - [con:22(guest@/127.0.0.1:52356/default)/ch:1] [con:22(guest@/127.0.0.1:52356/default)/ch:1] CHN-1002 : Flow Stopped
2016-10-18 15:01:49,167 INFO  [IO-/127.0.0.1:52356] (q.m.c.flow) - [con:22(guest@/127.0.0.1:52356/default)/ch:1] [con:22(guest@/127.0.0.1:52356/default)/ch:1] CHN-1002 : Flow Started
2016-10-18 15:01:49,187 INFO  [IO-/127.0.0.1:52356] (q.m.c.close) - [con:22(guest@/127.0.0.1:52356/default)/ch:1] [con:22(guest@/127.0.0.1:52356/default)/ch:1] CHN-1003 : Close
2016-10-18 15:01:49,190 INFO  [IO-/127.0.0.1:52356] (q.m.c.create) - [con:22(guest@/127.0.0.1:52356/default)/ch:2] CHN-1001 : Create
2016-10-18 15:01:49,200 INFO  [IO-/127.0.0.1:52356] (q.m.c.prefetch_size) - [con:22(guest@/127.0.0.1:52356/default)/ch:2] CHN-1004 : Prefetch Size (bytes) 0 : Count 500
2016-10-18 15:01:49,219 INFO  [IO-/127.0.0.1:52357] (q.m.c.open) - [con:23(/127.0.0.1:52357)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9
2016-10-18 15:01:49,304 INFO  [IO-/127.0.0.1:52357] (q.m.c.open) - [con:23(guest@/127.0.0.1:52357/default)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9 : Client ID : clientid : Client Version : 6.1.0-SNAPSHOT : Client Product : qpid
2016-10-18 15:01:49,310 INFO  [IO-/127.0.0.1:52357] (q.m.c.create) - [con:23(guest@/127.0.0.1:52357/default)/ch:1] CHN-1001 : Create
2016-10-18 15:01:49,315 INFO  [IO-/127.0.0.1:52357] (q.m.c.prefetch_size) - [con:23(guest@/127.0.0.1:52357/default)/ch:1] CHN-1004 : Prefetch Size (bytes) 0 : Count 3
2016-10-18 15:01:49,319 INFO  [IO-/127.0.0.1:52357] (q.m.c.flow) - [con:23(guest@/127.0.0.1:52357/default)/ch:1] [con:23(guest@/127.0.0.1:52357/default)/ch:1] CHN-1002 : Flow Stopped
2016-10-18 15:01:49,322 INFO  [IO-/127.0.0.1:52357] (q.m.c.flow) - [con:23(guest@/127.0.0.1:52357/default)/ch:1] [con:23(guest@/127.0.0.1:52357/default)/ch:1] CHN-1002 : Flow Started
2016-10-18 15:01:49,347 INFO  [IO-/127.0.0.1:52357] (q.m.c.close) - [con:23(guest@/127.0.0.1:52357/default)/ch:1] [con:23(guest@/127.0.0.1:52357/default)/ch:1] CHN-1003 : Close
2016-10-18 15:01:49,350 INFO  [IO-/127.0.0.1:52357] (q.m.c.create) - [con:23(guest@/127.0.0.1:52357/default)/ch:2] CHN-1001 : Create
2016-10-18 15:01:49,359 INFO  [IO-/127.0.0.1:52357] (q.m.c.prefetch_size) - [con:23(guest@/127.0.0.1:52357/default)/ch:2] CHN-1004 : Prefetch Size (bytes) 0 : Count 500
2016-10-18 15:01:49,383 INFO  [IO-/127.0.0.1:52358] (q.m.c.open) - [con:24(/127.0.0.1:52358)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9
2016-10-18 15:01:49,451 INFO  [IO-/127.0.0.1:52358] (q.m.c.open) - [con:24(guest@/127.0.0.1:52358/default)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9 : Client ID : clientid : Client Version : 6.1.0-SNAPSHOT : Client Product : qpid
2016-10-18 15:01:49,456 INFO  [IO-/127.0.0.1:52358] (q.m.c.create) - [con:24(guest@/127.0.0.1:52358/default)/ch:1] CHN-1001 : Create
2016-10-18 15:01:49,461 INFO  [IO-/127.0.0.1:52358] (q.m.c.prefetch_size) - [con:24(guest@/127.0.0.1:52358/default)/ch:1] CHN-1004 : Prefetch Size (bytes) 0 : Count 3
2016-10-18 15:01:49,468 INFO  [IO-/127.0.0.1:52358] (q.m.c.flow) - [con:24(guest@/127.0.0.1:52358/default)/ch:1] [con:24(guest@/127.0.0.1:52358/default)/ch:1] CHN-1002 : Flow Stopped
2016-10-18 15:01:49,472 INFO  [IO-/127.0.0.1:52358] (q.m.c.flow) - [con:24(guest@/127.0.0.1:52358/default)/ch:1] [con:24(guest@/127.0.0.1:52358/default)/ch:1] CHN-1002 : Flow Started
2016-10-18 15:01:49,482 INFO  [IO-/127.0.0.1:52358] (q.m.c.close) - [con:24(guest@/127.0.0.1:52358/default)/ch:1] [con:24(guest@/127.0.0.1:52358/default)/ch:1] CHN-1003 : Close
2016-10-18 15:01:49,484 INFO  [IO-/127.0.0.1:52358] (q.m.c.create) - [con:24(guest@/127.0.0.1:52358/default)/ch:2] CHN-1001 : Create
2016-10-18 15:01:49,487 INFO  [IO-/127.0.0.1:52358] (q.m.c.prefetch_size) - [con:24(guest@/127.0.0.1:52358/default)/ch:2] CHN-1004 : Prefetch Size (bytes) 0 : Count 500
2016-10-18 15:01:49,495 INFO  [IO-/127.0.0.1:52359] (q.m.c.open) - [con:25(/127.0.0.1:52359)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9
2016-10-18 15:01:49,559 INFO  [IO-/127.0.0.1:52359] (q.m.c.open) - [con:25(guest@/127.0.0.1:52359/default)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9 : Client ID : clientid : Client Version : 6.1.0-SNAPSHOT : Client Product : qpid
2016-10-18 15:01:49,563 INFO  [IO-/127.0.0.1:52359] (q.m.c.create) - [con:25(guest@/127.0.0.1:52359/default)/ch:1] CHN-1001 : Create
2016-10-18 15:01:49,575 INFO  [IO-/127.0.0.1:52359] (q.m.c.prefetch_size) - [con:25(guest@/127.0.0.1:52359/default)/ch:1] CHN-1004 : Prefetch Size (bytes) 0 : Count 3
2016-10-18 15:01:49,577 INFO  [IO-/127.0.0.1:52359] (q.m.c.flow) - [con:25(guest@/127.0.0.1:52359/default)/ch:1] [con:25(guest@/127.0.0.1:52359/default)/ch:1] CHN-1002 : Flow Stopped
2016-10-18 15:01:49,580 INFO  [IO-/127.0.0.1:52359] (q.m.c.flow) - [con:25(guest@/127.0.0.1:52359/default)/ch:1] [con:25(guest@/127.0.0.1:52359/default)/ch:1] CHN-1002 : Flow Started
2016-10-18 15:01:49,613 INFO  [IO-/127.0.0.1:52359] (q.m.c.close) - [con:25(guest@/127.0.0.1:52359/default)/ch:1] [con:25(guest@/127.0.0.1:52359/default)/ch:1] CHN-1003 : Close
2016-10-18 15:01:49,615 INFO  [IO-/127.0.0.1:52359] (q.m.c.create) - [con:25(guest@/127.0.0.1:52359/default)/ch:2] CHN-1001 : Create
2016-10-18 15:01:49,622 INFO  [IO-/127.0.0.1:52359] (q.m.c.prefetch_size) - [con:25(guest@/127.0.0.1:52359/default)/ch:2] CHN-1004 : Prefetch Size (bytes) 0 : Count 500
2016-10-18 15:01:49,632 INFO  [IO-/127.0.0.1:52361] (q.m.c.open) - [con:26(/127.0.0.1:52361)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9
2016-10-18 15:01:49,719 INFO  [IO-/127.0.0.1:52361] (q.m.c.open) - [con:26(guest@/127.0.0.1:52361/default)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9 : Client ID : clientid : Client Version : 6.1.0-SNAPSHOT : Client Product : qpid
2016-10-18 15:01:49,732 INFO  [IO-/127.0.0.1:52361] (q.m.c.create) - [con:26(guest@/127.0.0.1:52361/default)/ch:1] CHN-1001 : Create
2016-10-18 15:01:49,739 INFO  [IO-/127.0.0.1:52361] (q.m.c.prefetch_size) - [con:26(guest@/127.0.0.1:52361/default)/ch:1] CHN-1004 : Prefetch Size (bytes) 0 : Count 3
2016-10-18 15:01:49,742 INFO  [IO-/127.0.0.1:52361] (q.m.c.flow) - [con:26(guest@/127.0.0.1:52361/default)/ch:1] [con:26(guest@/127.0.0.1:52361/default)/ch:1] CHN-1002 : Flow Stopped
2016-10-18 15:01:49,755 INFO  [IO-/127.0.0.1:52361] (q.m.c.flow) - [con:26(guest@/127.0.0.1:52361/default)/ch:1] [con:26(guest@/127.0.0.1:52361/default)/ch:1] CHN-1002 : Flow Started
2016-10-18 15:01:49,767 INFO  [IO-/127.0.0.1:52361] (q.m.c.close) - [con:26(guest@/127.0.0.1:52361/default)/ch:1] [con:26(guest@/127.0.0.1:52361/default)/ch:1] CHN-1003 : Close
2016-10-18 15:01:49,769 INFO  [IO-/127.0.0.1:52361] (q.m.c.create) - [con:26(guest@/127.0.0.1:52361/default)/ch:2] CHN-1001 : Create
2016-10-18 15:01:49,775 INFO  [IO-/127.0.0.1:52361] (q.m.c.prefetch_size) - [con:26(guest@/127.0.0.1:52361/default)/ch:2] CHN-1004 : Prefetch Size (bytes) 0 : Count 500
2016-10-18 15:01:49,790 INFO  [IO-/127.0.0.1:52362] (q.m.c.open) - [con:27(/127.0.0.1:52362)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9
2016-10-18 15:01:49,848 INFO  [IO-/127.0.0.1:52362] (q.m.c.open) - [con:27(guest@/127.0.0.1:52362/default)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9 : Client ID : clientid : Client Version : 6.1.0-SNAPSHOT : Client Product : qpid
2016-10-18 15:01:49,855 INFO  [IO-/127.0.0.1:52362] (q.m.c.create) - [con:27(guest@/127.0.0.1:52362/default)/ch:1] CHN-1001 : Create
2016-10-18 15:01:49,866 INFO  [IO-/127.0.0.1:52362] (q.m.c.prefetch_size) - [con:27(guest@/127.0.0.1:52362/default)/ch:1] CHN-1004 : Prefetch Size (bytes) 0 : Count 3
2016-10-18 15:01:49,869 INFO  [IO-/127.0.0.1:52362] (q.m.c.flow) - [con:27(guest@/127.0.0.1:52362/default)/ch:1] [con:27(guest@/127.0.0.1:52362/default)/ch:1] CHN-1002 : Flow Stopped
2016-10-18 15:01:49,878 INFO  [IO-/127.0.0.1:52362] (q.m.c.flow) - [con:27(guest@/127.0.0.1:52362/default)/ch:1] [con:27(guest@/127.0.0.1:52362/default)/ch:1] CHN-1002 : Flow Started
2016-10-18 15:01:49,892 INFO  [IO-/127.0.0.1:52362] (q.m.c.close) - [con:27(guest@/127.0.0.1:52362/default)/ch:1] [con:27(guest@/127.0.0.1:52362/default)/ch:1] CHN-1003 : Close
2016-10-18 15:01:49,895 INFO  [IO-/127.0.0.1:52362] (q.m.c.create) - [con:27(guest@/127.0.0.1:52362/default)/ch:2] CHN-1001 : Create
2016-10-18 15:01:49,901 INFO  [IO-/127.0.0.1:52362] (q.m.c.prefetch_size) - [con:27(guest@/127.0.0.1:52362/default)/ch:2] CHN-1004 : Prefetch Size (bytes) 0 : Count 500
2016-10-18 15:01:49,920 INFO  [IO-/127.0.0.1:52363] (q.m.c.open) - [con:28(/127.0.0.1:52363)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9
2016-10-18 15:01:50,060 INFO  [IO-/127.0.0.1:52363] (q.m.c.open) - [con:28(guest@/127.0.0.1:52363/default)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9 : Client ID : clientid : Client Version : 6.1.0-SNAPSHOT : Client Product : qpid
2016-10-18 15:01:50,064 INFO  [IO-/127.0.0.1:52363] (q.m.c.create) - [con:28(guest@/127.0.0.1:52363/default)/ch:1] CHN-1001 : Create
2016-10-18 15:01:50,072 INFO  [IO-/127.0.0.1:52363] (q.m.c.prefetch_size) - [con:28(guest@/127.0.0.1:52363/default)/ch:1] CHN-1004 : Prefetch Size (bytes) 0 : Count 3
2016-10-18 15:01:50,083 INFO  [IO-/127.0.0.1:52363] (q.m.c.flow) - [con:28(guest@/127.0.0.1:52363/default)/ch:1] [con:28(guest@/127.0.0.1:52363/default)/ch:1] CHN-1002 : Flow Stopped
2016-10-18 15:01:50,087 INFO  [IO-/127.0.0.1:52363] (q.m.c.flow) - [con:28(guest@/127.0.0.1:52363/default)/ch:1] [con:28(guest@/127.0.0.1:52363/default)/ch:1] CHN-1002 : Flow Started
2016-10-18 15:01:50,095 INFO  [IO-/127.0.0.1:52363] (q.m.c.close) - [con:28(guest@/127.0.0.1:52363/default)/ch:1] [con:28(guest@/127.0.0.1:52363/default)/ch:1] CHN-1003 : Close
2016-10-18 15:01:50,098 INFO  [IO-/127.0.0.1:52363] (q.m.c.create) - [con:28(guest@/127.0.0.1:52363/default)/ch:2] CHN-1001 : Create
2016-10-18 15:01:50,101 INFO  [IO-/127.0.0.1:52363] (q.m.c.prefetch_size) - [con:28(guest@/127.0.0.1:52363/default)/ch:2] CHN-1004 : Prefetch Size (bytes) 0 : Count 500
2016-10-18 15:01:50,113 INFO  [IO-/127.0.0.1:52364] (q.m.c.open) - [con:29(/127.0.0.1:52364)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9
2016-10-18 15:01:50,171 INFO  [IO-/127.0.0.1:52364] (q.m.c.open) - [con:29(guest@/127.0.0.1:52364/default)] CON-1001 : Open : Destination : AMQP(127.0.0.1:5672) : Protocol Version : 0-9 : Client ID : clientid : Client Version : 6.1.0-SNAPSHOT : Client Product : qpid
2016-10-18 15:01:50,174 INFO  [IO-/127.0.0.1:52364] (q.m.c.create) - [con:29(guest@/127.0.0.1:52364/default)/ch:1] CHN-1001 : Create
2016-10-18 15:01:50,184 INFO  [IO-/127.0.0.1:52364] (q.m.c.prefetch_size) - [con:29(guest@/127.0.0.1:52364/default)/ch:1] CHN-1004 : Prefetch Size (bytes) 0 : Count 3
2016-10-18 15:01:50,193 INFO  [IO-/127.0.0.1:52364] (q.m.c.flow) - [con:29(guest@/127.0.0.1:52364/default)/ch:1] [con:29(guest@/127.0.0.1:52364/default)/ch:1] CHN-1002 : Flow Stopped
2016-10-18 15:01:50,201 INFO  [IO-/127.0.0.1:52364] (q.m.c.flow) - [con:29(guest@/127.0.0.1:52364/default)/ch:1] [con:29(guest@/127.0.0.1:52364/default)/ch:1] CHN-1002 : Flow Started
2016-10-18 15:01:50,213 INFO  [IO-/127.0.0.1:52364] (q.m.c.close) - [con:29(guest@/127.0.0.1:52364/default)/ch:1] [con:29(guest@/127.0.0.1:52364/default)/ch:1] CHN-1003 : Close
2016-10-18 15:01:50,223 INFO  [IO-/127.0.0.1:52364] (q.m.c.create) - [con:29(guest@/127.0.0.1:52364/default)/ch:2] CHN-1001 : Create
2016-10-18 15:01:50,240 INFO  [IO-/127.0.0.1:52364] (q.m.c.prefetch_size) - [con:29(guest@/127.0.0.1:52364/default)/ch:2] CHN-1004 : Prefetch Size (bytes) 0 : Count 500
2016-10-18 15:01:50,439 INFO  [VirtualHostNode-default-Config] (q.m.q.created) - [con:0(guest@/127.0.0.1:52328/default)/ch:2] [vh(/default)/qu(testQueue)] QUE-1001 : Create : ID: c2d755b1-29ac-4335-bb61-95c28369f609 Durable
2016-10-18 15:01:50,536 INFO  [VirtualHostNode-default-Config] (q.m.b.created) - [con:0(guest@/127.0.0.1:52328/default)/ch:2] [vh(/default)/ex(direct/amq.direct)/qu(testQueue)/rk(testQueue)] BND-1001 : Create
2016-10-18 15:01:50,557 INFO  [IO-/127.0.0.1:52328] (q.m.c.flow) - [con:0(guest@/127.0.0.1:52328/default)/ch:2] [con:0(guest@/127.0.0.1:52328/default)/ch:2] CHN-1002 : Flow Stopped
2016-10-18 15:01:50,616 INFO  [VirtualHostNode-default-Config] (q.m.s.create) - [con:0(guest@/127.0.0.1:52328/default)/ch:2] [sub:30(vh(/default)/qu(testQueue)] SUB-1001 : Create
2016-10-18 15:01:50,637 INFO  [VirtualHostNode-default-Config] (q.m.s.close) - [con:0(guest@/127.0.0.1:52328/default)/ch:2] [sub:30(vh(/default)/qu(testQueue)] SUB-1002 : Close
2016-10-18 15:03:54,005 INFO  [IO-/127.0.0.1:52353] (q.m.q.flow_to_disk_active) - [con:19(guest@/127.0.0.1:52353/default)] [vh(/default)/qu(testQueue)] QUE-1014 : Message flow to disk active :  Message memory use 629156 kB exceeds threshold 629145 kB
2016-10-18 15:04:11,733 INFO  [Housekeeping[default]] (q.m.b.flow_to_disk_active) - [Housekeeping[default]] BRK-1014 : Message flow to disk active :  Message memory use 738408KB exceeds threshold 629145KB
/*
 *
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF licenses this file
 * to you under the Apache License, Version 2.0 (the
 * "License"); you may not use this file except in compliance
 * with the License.  You may obtain a copy of the License at
 *
 *   http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing,
 * software distributed under the License is distributed on an
 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
 * KIND, either express or implied.  See the License for the
 * specific language governing permissions and limitations
 * under the License.
 *
 */

package org.apache.qpid.example;

import java.io.InputStream;
import java.util.Objects;
import java.util.Properties;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

import javax.jms.BytesMessage;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.DeliveryMode;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.MessageConsumer;
import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.naming.Context;
import javax.naming.InitialContext;


public class Hello 
{

    public Hello() 
    {
    }

    public static void main(String[] args)
    {
        Hello hello = new Hello();
        hello.runTest();
    }

    private void runTest() 
    {
        try (InputStream resourceAsStream = this.getClass().getResourceAsStream("hello.properties"))
        {
            Properties properties = new Properties();
            properties.load(resourceAsStream);
            Context context = new InitialContext(properties);

            ConnectionFactory connectionFactory = (ConnectionFactory) context.lookup("qpidConnectionfactory");
            Connection[] connections = new Connection[30];
            Session[] sessions = new Session[30];
            for (int i = 0; i < 30; ++i)
            {
                connections[i] = connectionFactory.createConnection();
                connections[i].start();
                sessions[i] = connections[i].createSession(true, Session.SESSION_TRANSACTED);
            }
            final Destination destination = (Destination) context.lookup("myQueue");

            sessions[0].createConsumer(destination).close();

            final ExecutorService executor = Executors.newFixedThreadPool(30);
            for (int i = 0; i < 30; ++i)
            {
                final Session s = sessions[i];
                executor.submit(new Callable<Object>()
                                {
                                    @Override
                                    public Object call() throws Exception
                                    {
                                        produce(s, destination);
                                        return null;
                                    }
                                }
                               );
            }
            executor.awaitTermination(1, TimeUnit.DAYS);
            for (int i = 0; i < 30; ++i)
            {
                sessions[i].close();
                connections[i].close();
            }
            context.close();
        }
        catch (Exception exp) 
        {
            exp.printStackTrace();
        }
    }

    private void produce(final Session session, final Destination destination) throws JMSException
    {
        MessageProducer messageProducer = session.createProducer(destination);
        try
        {
            BytesMessage message = session.createBytesMessage();
            message.writeBytes(new byte[10 * 1024]);
            message.setJMSDeliveryMode(DeliveryMode.PERSISTENT);
            long N = 1000000L;
            for (long i = 0; i < N; ++i)
            {
                messageProducer.send(message);
                session.commit();
                if (i % 100 == 0)
                {
                    System.out.println(i);
                }
            }
        }
        finally
        {
            messageProducer.close();
            session.close();
        }
    }
}

---------------------------------------------------------------------
To unsubscribe, e-mail: users-unsubscr...@qpid.apache.org
For additional commands, e-mail: users-h...@qpid.apache.org

Reply via email to