The msmq: component is a transport for working with Microsoft Message Queuing This component natively sends and receives directly
allocated ByteBuffer instances. This allows you to access the JNI layer
without expensive memory copying. In fact, if a ByteBuffer is created by
the allocateDirect method, it can be passed to the JNI layer and the native
code is able to access the memory directly. It's up to the developer to marshal/unmarshal any
other kinds of payload to/from directly allocated ByteBuffer instances.
Look at the tests to see some usage examples.
msmq:msmqQueueName[?options]
You can append query options to the URI in the following format,
?option=value&option=value&...
msmq:DIRECT=OS:localhost\\private$\\test?concurrentConsumers=1 msmq:DIRECT=OS:localhost\\private$\\test?deliveryPersistent=true&priority=5&timeToLive=10
| Name | Default Value | Description |
|---|---|---|
deliveryPersistent
|
false
|
If true, the message is put persistently on the queue. |
priority
|
5
|
The message priority, lying in the range 1-7 |
timeToLive
|
INFINITE
|
The maximum amount of time (specified in seconds) that a message can spend travelling to its destination. If this limit is exceeded, the message is discarded. |
concurrentConsumers
|
1
|
The numbers of consumers that get messages from the queue at the same time. |
initialBufferSize
|
128
|
The initial buffer size |
incrementBufferSize
|
128
|
If the initial buffer size is not enough big for the received message, it is
incremented by incrementBufferSize
|
 |  | |
 |
