|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
readerIndex
and writerIndex
of this buffer to
0
.
true
if this message contains a property with the given key, false
else.
QueueControl.listMessageCounterHistory()
.readerIndex
.
FirstElementConnectionLoadBalancingPolicy.select(int)
always returns 0.AddressControl.getRolesAsJSON()
.
TopicControl.listAllSubscriptionsAsJSON()
and related methods.
TopicControl.listAllSubscriptionsAsJSON()
and related methods.
QueueControl.listMessageCounterHistory()
.
QueueControl.listMessageCounter()
.
index
in this buffer.
index
until the destination becomes
non-writable.
index
.
index
.
index
.
index
.
index
until the destination's position
reaches its limit.
index
in
this buffer.
null
if it is not set.
null
.
index
in
this buffer.
null
if the queue has no filter).
index
in
this buffer.
Message.HDR_GROUP_ID
.
index
in
this buffer.
NIO
or ASYNCIO
).
index
in
this buffer.
index
in
this buffer.
index
in this
buffer.
index
in this buffer.
index
in this buffer.
ClientSessionFactory
objects.false
else
false
else
true
if this server is a backup, false
if it is a live server.
true
, consumers created through this factory will create temporary files to cache large messages.
true
if the queue is durable, false
else.
true
if the binding exists, false
else.
true
if the queue exists, false
else.
HornetQClient.DEFAULT_FAILOVER_ON_INITIAL_CONNECTION
.
BufferHandler.bufferReceived(Object, org.hornetq.api.core.HornetQBuffer)
.
true
if the current transaction has been flagged to rollback, false
else.
true
if this component is started, false
else.
true
if the session supports XA, false
else.
JMSServerControl.listConsumersAsJSON(String)
and related methods.LogDelegate
instances.readerIndex
in this buffer.
writerIndex
in this buffer.
QueueControl.listMessageCounter()
.RandomConnectionLoadBalancingPolicy.select(int)
returns a random integer between 0
(inclusive) and max
(exclusive)RandomConnectionLoadBalancingPolicy.select(int)
chooses a the initial node randomly then subsequent requests return the same nodetrue
if and only if (this.writerIndex - this.readerIndex)
is greater
than 0
.
(this.writerIndex - this.readerIndex)
.
readerIndex
and increases the readerIndex
by 1
in this buffer.
readerIndex
and increases
the readerIndex
by 1
in this buffer.
readerIndex
and increases the readerIndex
by the number of the transferred bytes (= length
).
readerIndex
until the destination becomes
non-writable, and increases the readerIndex
by the number of the
transferred bytes.
readerIndex
and increases the readerIndex
by the number of the transferred bytes (= length
).
readerIndex
and increases the readerIndex
by the number of the transferred bytes (= length
).
readerIndex
and increases the readerIndex
by the number of the transferred bytes (= dst.length
).
readerIndex
and increases the readerIndex
by the number of the transferred bytes (= length
).
readerIndex
until the destination's position
reaches its limit, and increases the readerIndex
by the
number of the transferred bytes.
readerIndex
and increases the readerIndex
by 2
in this buffer.
readerIndex
and increases the readerIndex
by 8
in this buffer.
readerIndex
of this buffer.
readerIndex
of this buffer.
readerIndex
and increases the readerIndex
by 4
in this buffer.
readerIndex
and increases the readerIndex
by 4
in this buffer.
readerIndex
and increases the readerIndex
by 8
in this buffer.
null
) at the current readerIndex
null
) at the current readerIndex
readerIndex
and increases the readerIndex
by 2
in this buffer.
readerIndex
readerIndex
and increases the readerIndex
by the size
of the new slice (= length
).
readerIndex
readerIndex
and increases
the readerIndex
by 1
in this buffer.
readerIndex
and increases the readerIndex
by 4
in this buffer.
readerIndex
and increases the readerIndex
by 2
in this buffer.
readerIndex
readerIndex
to the marked
readerIndex
in this buffer.
writerIndex
to the marked
writerIndex
in this buffer.
AddressControl.getRolesAsJSON()
.index
in this
buffer.
index
until the destination becomes
unreadable.
index
.
index
.
index
.
index
.
index
until the source buffer's position
reaches its limit.
index
in this buffer.
index
in this buffer.
index
in this buffer.
readerIndex
and writerIndex
of this buffer
in one shot.
index
in this buffer.
index
in this buffer.
true
to pre-acknowledge consumed messages on the server before they are sent to consumers, else set to false
to let
clients acknowledge the message they consume.
SendAcknowledgementHandler
for this session.
index
in this buffer.
readerIndex
by the specified
length
in this buffer.
TopicControl.listAllSubscriptionsAsJSON()
and related methods.string
parameter.
ConnectorFactory
and any parameters needed.
ConnectorFactory
and any parameters needed.
ConnectorFactory
true
if and only if (this.capacity - this.writerIndex)
is greater
than 0
.
(this.capacity - this.writerIndex)
.
writerIndex
writerIndex
and increases the writerIndex
by 1
in this buffer.
writerIndex
and increases the writerIndex
by the number of the transferred bytes (= length
).
writerIndex
and increases the writerIndex
by the number of the transferred bytes (= length
).
writerIndex
and increases the writerIndex
by the number of the transferred bytes (= src.length
).
writerIndex
and increases the writerIndex
by the number of the transferred bytes (= length
).
writerIndex
until the source buffer's position
reaches its limit, and increases the writerIndex
by the
number of the transferred bytes.
writerIndex
and increases the writerIndex
by 2
in this buffer.
writerIndex
and increases the writerIndex
by 8
in this buffer.
writerIndex
and increases the writerIndex
by 4
in this buffer.
writerIndex
and increases the writerIndex
by 4
in this buffer.
writerIndex
and increases the writerIndex
by 8
in this buffer.
null
) at the current writerIndex
null
) at the current writerIndex
writerIndex
of this buffer.
writerIndex
of this buffer.
writerIndex
and increases the writerIndex
by 2
in this buffer.
writerIndex
writerIndex
writerIndex
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |