Public Pastes
SHARE
TWEET

QPid ignoring requeue: false

a guest Jan 19th, 2017 71 Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
  1. T+9371 [IO-/127.0.0.1:50702] DEBUG o.a.q.s.t.NonBlockingConnection - Read 13 byte(s)
  2. T+9371 [IO-/127.0.0.1:50702] DEBUG o.a.q.s.p.v.AMQPConnection_0_8Impl - RECV[2] ChannelOpen
  3. T+9371 [IO-/127.0.0.1:50702] DEBUG o.a.q.s.p.v.AMQPConnection_0_8Impl - Connecting to: base
  4. T+9372 [IO-/127.0.0.1:50702] INFO  qpid.message.channel.create - [con:0(guest@/127.0.0.1:50702/base)/ch:2] CHN-1001 : Create
  5. T+9373 [VirtualHostNode-${qpid.vhost}-Config] DEBUG o.a.q.s.c.updater.TaskExecutorImpl - Performing Task['create' on 'Session[id=010a807f-e987-42dc-a925-6447fb22bb05, name=2, type=Session]']
  6. T+9374 [IO-/127.0.0.1:50702] DEBUG o.a.q.s.p.v.AMQPConnection_0_8Impl - SEND: Frame channelId: 2, bodyFrame: [ChannelOpenOkBody]
  7. T+9374 [VirtualHostNode-${qpid.vhost}-Config] DEBUG o.a.q.s.c.updater.TaskExecutorImpl - Task['create' on 'Session[id=010a807f-e987-42dc-a925-6447fb22bb05, name=2, type=Session]'] performed successfully with result: null
  8. T+9374 [IO-/127.0.0.1:50702] DEBUG o.a.q.s.protocol.v0_8.BrokerDecoder - Frame handled in 3 ms.
  9. T+9374 [IO-/127.0.0.1:50702] DEBUG o.a.q.s.t.NonBlockingConnection - Written 16 bytes
  10. T+9374 [IO-/127.0.0.1:50702] DEBUG o.a.q.s.t.NonBlockingConnection - Read 0 byte(s)
  11. T+9375 [IO-/127.0.0.1:50702] DEBUG o.a.q.s.t.NonBlockingConnection - Read 13 byte(s)
  12. T+9375 [IO-/127.0.0.1:50702] DEBUG o.a.q.s.protocol.v0_8.AMQChannel - RECV[2] ConfirmSelect [ nowait: false ]
  13. T+9375 [IO-/127.0.0.1:50702] DEBUG o.a.q.s.p.v.AMQPConnection_0_8Impl - SEND: Frame channelId: 2, bodyFrame: [ConfirmSelectOkBody]
  14. T+9375 [IO-/127.0.0.1:50702] DEBUG o.a.q.s.protocol.v0_8.BrokerDecoder - Frame handled in 0 ms.
  15. T+9375 [IO-/127.0.0.1:50702] DEBUG o.a.q.s.protocol.v0_8.AMQChannel - sync() called on channel 2(585286696)
  16. T+9375 [IO-/127.0.0.1:50702] DEBUG o.a.q.s.t.NonBlockingConnection - Written 12 bytes
  17. T+9375 [IO-/127.0.0.1:50702] DEBUG o.a.q.s.t.NonBlockingConnection - Read 0 byte(s)
  18. T+9379 [IO-/127.0.0.1:50702] DEBUG o.a.q.s.t.NonBlockingConnection - Read 200 byte(s)
  19. T+9380 [IO-/127.0.0.1:50702] DEBUG o.a.q.s.protocol.v0_8.AMQChannel - RECV[2] BasicPublish[ exchange: null routingKey: myqueue mandatory: true immediate: false ]
  20. T+9381 [IO-/127.0.0.1:50702] DEBUG o.a.q.s.protocol.v0_8.BrokerDecoder - Frame handled in 2 ms.
  21. T+9382 [IO-/127.0.0.1:50702] DEBUG o.a.q.f.BasicContentHeaderProperties - Property flags: 63488
  22. T+9383 [IO-/127.0.0.1:50702] DEBUG o.a.q.s.protocol.v0_8.AMQChannel - RECV[2] MessageHeader[ properties: {reply-to = null,propertyFlags = 63488,ApplicationID = null,ClusterID = null,UserId = null,JMSMessageID = null,JMSCorrelationID = null,JMSDeliveryMode = 2,JMSExpiration = 0,JMSPriority = 0,JMSTimestamp = 0,JMSType = null,contentType = application/json} bodySize: 5 ]
  23. T+9383 [IO-/127.0.0.1:50702] DEBUG o.a.q.s.protocol.v0_8.AMQChannel - Content header received on channel 2
  24. T+9383 [IO-/127.0.0.1:50702] DEBUG o.a.q.s.protocol.v0_8.BrokerDecoder - Frame handled in 2 ms.
  25. T+9384 [IO-/127.0.0.1:50702] DEBUG o.a.q.s.protocol.v0_8.AMQChannel - RECV[2] MessageContent[ data: 224f6e6522 ]
  26. T+9384 [IO-/127.0.0.1:50702] DEBUG o.a.q.s.protocol.v0_8.AMQChannel - 2(585286696) content body received on channel 2
  27. T+9388 [IO-/127.0.0.1:50702] DEBUG o.a.q.s.t.AsyncAutoCommitTransaction - Enqueue of message number 1 to transaction log. Queue : myqueue
  28. T+9390 [IO-/127.0.0.1:50702] DEBUG o.a.q.s.p.v.AMQPConnection_0_8Impl - SEND: Frame channelId: 2, bodyFrame: [BasicAckBodyImpl: deliveryTag=1, multiple=false]
  29. T+9390 [IO-/127.0.0.1:50702] DEBUG o.a.q.s.protocol.v0_8.BrokerDecoder - Frame handled in 7 ms.
  30. T+9390 [IO-/127.0.0.1:50702] DEBUG o.a.q.s.protocol.v0_8.AMQChannel - sync() called on channel 2(585286696)
  31. T+9392 [IO-/127.0.0.1:50702] DEBUG o.a.q.s.t.NonBlockingConnection - Written 21 bytes
  32. T+9392 [IO-/127.0.0.1:50702] DEBUG o.a.q.s.t.NonBlockingConnection - Read 0 byte(s)
  33. T+9394 [IO-/127.0.0.1:50702] DEBUG o.a.q.s.protocol.v0_8.AMQChannel - 1(1450144548) Adding unacked message(Message[(HC:1100301661 ID:1 Ref:2)] DT:1) for Consumer[id=b6603e35-2529-43e2-bc11-715a5203c23e, name=sgen_1, type=Consumer] on myqueue
  34. T+9397 [IO-/127.0.0.1:50702] DEBUG o.a.q.s.p.v.AMQPConnection_0_8Impl - SEND: [CompositeAMQBodyBlock methodBody=[EncodedDeliveryBody underlyingBody: null], headerBody=ContentHeaderBody{classId=60, weight=0, bodySize=5, properties=reply-to = null,propertyFlags = 63488,ApplicationID = null,ClusterID = null,UserId = null,JMSMessageID = null,JMSCorrelationID = null,JMSDeliveryMode = 2,JMSExpiration = 0,JMSPriority = 0,JMSTimestamp = 0,JMSType = null,contentType = application/json}, contentBody=[MessageContentSourceBody offset: 0, length: 5], channel=1]
  35. T+9398 [IO-/127.0.0.1:50702] DEBUG o.a.q.s.t.NonBlockingConnection - Read 0 byte(s)
  36. T+9398 [IO-/127.0.0.1:50702] DEBUG o.a.q.s.t.NonBlockingConnection - Written 213 bytes
  37. ----
  38. throw new AmqpRejectAndDontRequeueException
  39. ----
  40. T+9426 [IO-/127.0.0.1:50702] DEBUG o.a.q.s.t.NonBlockingConnection - Read 21 byte(s)
  41. T+9427 [IO-/127.0.0.1:50702] DEBUG o.a.q.s.protocol.v0_8.AMQChannel - RECV[1] BasicReject[ deliveryTag: 1 requeue: false ]
  42. T+9427 [IO-/127.0.0.1:50702] DEBUG o.a.q.s.protocol.v0_8.AMQChannel - Rejecting: DT:1-Message[(HC:1100301661 ID:1 Ref:1)]: Requeue:false on channel:1(1450144548)
  43. T+9427 [IO-/127.0.0.1:50702] DEBUG o.a.q.s.protocol.v0_8.AMQChannel - maxDeliveryCountEnabled: false deliveryTag 1
  44. T+9427 [IO-/127.0.0.1:50702] DEBUG o.a.q.s.protocol.v0_8.BrokerDecoder - Frame handled in 1 ms.
  45. T+9427 [IO-/127.0.0.1:50702] DEBUG o.a.q.s.protocol.v0_8.AMQChannel - sync() called on channel 1(1450144548)
  46. T+9428 [IO-/127.0.0.1:50702] DEBUG o.a.q.s.protocol.v0_8.AMQChannel - 1(1450144548) Adding unacked message(Message[(HC:1100301661 ID:1 Ref:2)] DT:2) for Consumer[id=b6603e35-2529-43e2-bc11-715a5203c23e, name=sgen_1, type=Consumer] on myqueue
  47. T+9428 [IO-/127.0.0.1:50702] DEBUG o.a.q.s.p.v.AMQPConnection_0_8Impl - SEND: [CompositeAMQBodyBlock methodBody=[EncodedDeliveryBody underlyingBody: null], headerBody=ContentHeaderBody{classId=60, weight=0, bodySize=5, properties=reply-to = null,propertyFlags = 63488,ApplicationID = null,ClusterID = null,UserId = null,JMSMessageID = null,JMSCorrelationID = null,JMSDeliveryMode = 2,JMSExpiration = 0,JMSPriority = 0,JMSTimestamp = 0,JMSType = null,contentType = application/json}, contentBody=[MessageContentSourceBody offset: 0, length: 5], channel=1]
  48. T+9428 [IO-/127.0.0.1:50702] DEBUG o.a.q.s.t.NonBlockingConnection - Read 0 byte(s)
  49. T+9428 [IO-/127.0.0.1:50702] DEBUG o.a.q.s.t.NonBlockingConnection - Written 213 bytes
  50. T+9428 [IO-/127.0.0.1:50702] DEBUG o.a.q.s.t.NonBlockingConnection - Read 0 byte(s)
RAW Paste Data
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy. OK, I Understand
Not a member of Pastebin yet?
Sign Up, it unlocks many cool features!
 
Top