Constructor and Description |
---|
Broker(Action<Integer> shutdownAction) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractExchange.addCloseTask(Action<ExchangeImpl> task) |
void |
AbstractExchange.removeCloseTask(Action<ExchangeImpl> task) |
<M extends ServerMessage<? extends StorableMessageMetaData>> |
DefaultDestination.send(M message,
String routingAddress,
InstanceProperties instanceProperties,
ServerTransaction txn,
Action<? super MessageInstance> postEnqueueAction) |
<M extends ServerMessage<? extends StorableMessageMetaData>> |
AbstractExchange.send(M message,
String routingAddress,
InstanceProperties instanceProperties,
ServerTransaction txn,
Action<? super MessageInstance> postEnqueueAction) |
Constructor and Description |
---|
QpidSslRMIServerSocketFactory(SSLContext sslContext,
List<String> tlsProtocolWhiteList,
List<String> tlsProtocolBlackList,
List<String> tlsCipherSuiteWhiteList,
List<String> tlsCipherSuiteBlackList,
Action<Integer> action)
SslRMIServerSocketFactory which creates the ServerSocket using the
supplied SSLContext rather than the system default context normally
used by the superclass, allowing us to use a configuration-specified
key store.
|
Modifier and Type | Method and Description |
---|---|
int |
MessageInstance.routeToAlternate(Action<? super MessageInstance> action,
ServerTransaction txn) |
<M extends ServerMessage<? extends StorableMessageMetaData>> |
MessageDestination.send(M message,
String routingAddress,
InstanceProperties instanceProperties,
ServerTransaction txn,
Action<? super MessageInstance> postEnqueueAction)
Routes a message
|
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractConfiguredObject.applyToChildren(Action<ConfiguredObject<?>> action) |
Modifier and Type | Method and Description |
---|---|
void |
ServerSession.addDeleteTask(Action<? super ServerSession> task) |
void |
ServerSession.removeDeleteTask(Action<? super ServerSession> task) |
void |
AMQPConnection_0_10.setWorkListener(Action<ProtocolEngine> listener) |
Modifier and Type | Method and Description |
---|---|
void |
AMQChannel.addDeleteTask(Action<? super AMQChannel> task) |
void |
AMQChannel.removeDeleteTask(Action<? super AMQChannel> task) |
void |
AMQPConnection_0_8.setWorkListener(Action<ProtocolEngine> listener) |
Modifier and Type | Method and Description |
---|---|
void |
Session_1_0.addDeleteTask(Action<? super Session_1_0> task) |
void |
Session_1_0.removeDeleteTask(Action<? super Session_1_0> task) |
void |
AMQPConnection_1_0.setWorkListener(Action<ProtocolEngine> listener) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractQueue.addDeleteTask(Action<? super AMQQueue> task) |
protected void |
SortedQueueImpl.doEnqueue(ServerMessage message,
Action<? super MessageInstance> action,
MessageEnqueueRecord record) |
protected void |
AbstractQueue.doEnqueue(ServerMessage message,
Action<? super MessageInstance> action,
MessageEnqueueRecord enqueueRecord) |
void |
BaseQueue.enqueue(ServerMessage message,
Action<? super MessageInstance> action,
MessageEnqueueRecord record) |
void |
AbstractQueue.enqueue(ServerMessage message,
Action<? super MessageInstance> action,
MessageEnqueueRecord enqueueRecord) |
void |
AbstractQueue.removeDeleteTask(Action<? super AMQQueue> task) |
int |
QueueEntryImpl.routeToAlternate(Action<? super MessageInstance> action,
ServerTransaction txn) |
<M extends ServerMessage<? extends StorableMessageMetaData>> |
AbstractQueue.send(M message,
String routingAddress,
InstanceProperties instanceProperties,
ServerTransaction txn,
Action<? super MessageInstance> postEnqueueAction) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractAMQPConnection.addDeleteTask(Action<? super C> task) |
void |
AbstractAMQPConnection.removeDeleteTask(Action<? super C> task) |
void |
ProtocolEngine.setWorkListener(Action<ProtocolEngine> listener) |
void |
MultiVersionProtocolEngine.setWorkListener(Action<ProtocolEngine> listener) |
Modifier and Type | Method and Description |
---|---|
void |
DtxBranch.enqueue(TransactionLogResource queue,
EnqueueableMessage message,
Action<MessageEnqueueRecord> enqueueAction) |
Modifier and Type | Method and Description |
---|---|
void |
Deletable.addDeleteTask(Action<? super T> task) |
void |
Deletable.removeDeleteTask(Action<? super T> task) |
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.