Uses of Interface
org.apache.activemq.artemis.api.core.client.ClientMessage
-
-
Uses of ClientMessage in org.apache.activemq.artemis.api.core.client
Methods in org.apache.activemq.artemis.api.core.client that return ClientMessage Modifier and Type Method Description ClientMessageClientMessage. acknowledge()Acknowledges reception of this message.ClientMessageClientSession. createMessage(boolean durable)Creates a ClientMessage.ClientMessageClientSession. createMessage(byte type, boolean durable)Creates a ClientMessage.ClientMessageClientSession. createMessage(byte type, boolean durable, long expiration, long timestamp, byte priority)Creates a ClientMessage.ClientMessageClientMessage. individualAcknowledge()Acknowledges reception of a single message.ClientMessageClientMessage. putBooleanProperty(String key, boolean value)Overridden fromMessageto enable fluent APIClientMessageClientMessage. putBooleanProperty(SimpleString key, boolean value)Overridden fromMessageto enable fluent APIClientMessageClientMessage. putByteProperty(String key, byte value)Overridden fromMessageto enable fluent APIClientMessageClientMessage. putByteProperty(SimpleString key, byte value)Overridden fromMessageto enable fluent APIClientMessageClientMessage. putBytesProperty(String key, byte[] value)Overridden fromMessageto enable fluent APIClientMessageClientMessage. putBytesProperty(SimpleString key, byte[] value)Overridden fromMessageto enable fluent APIClientMessageClientMessage. putCharProperty(String key, char value)Overridden fromMessageto enable fluent APIClientMessageClientMessage. putCharProperty(SimpleString key, char value)Overridden fromMessageto enable fluent APIClientMessageClientMessage. putDoubleProperty(String key, double value)Overridden fromMessageto enable fluent APIClientMessageClientMessage. putDoubleProperty(SimpleString key, double value)Overridden fromMessageto enable fluent APIClientMessageClientMessage. putFloatProperty(String key, float value)Overridden fromMessageto enable fluent APIClientMessageClientMessage. putFloatProperty(SimpleString key, float value)Overridden fromMessageto enable fluent APIClientMessageClientMessage. putIntProperty(String key, int value)Overridden fromMessageto enable fluent APIClientMessageClientMessage. putIntProperty(SimpleString key, int value)Overridden fromMessageto enable fluent APIClientMessageClientMessage. putLongProperty(String key, long value)Overridden fromMessageto enable fluent APIClientMessageClientMessage. putLongProperty(SimpleString key, long value)Overridden fromMessageto enable fluent APIClientMessageClientMessage. putShortProperty(String key, short value)Overridden fromMessageto enable fluent APIClientMessageClientMessage. putShortProperty(SimpleString key, short value)Overridden fromMessageto enable fluent APIClientMessageClientMessage. putStringProperty(String key, String value)Overridden fromMessageto enable fluent APIClientMessageClientConsumer. receive()Receives a message from a queue.ClientMessageClientConsumer. receive(long timeout)Receives a message from a queue.ClientMessageClientConsumer. receiveImmediate()Receives a message from a queue.ClientMessageClientRequestor. request(ClientMessage request)Sends a message to the request address and wait indefinitely for a reply.ClientMessageClientRequestor. request(ClientMessage request, long timeout)Sends a message to the request address and wait for the given timeout for a reply.ClientMessageClientMessage. setBodyInputStream(InputStream bodyInputStream)Sets the body's IntputStream.ClientMessageClientMessage. setDeliveryCount(int deliveryCount)Sets the delivery count for this message.ClientMessageClientMessage. setOutputStream(OutputStream out)Sets the OutputStream that will receive the content of a message received in a non blocking way.ClientMessageClientMessage. writeBodyBufferBytes(byte[] bytes)Overridden fromMessageto enable fluent APIClientMessageClientMessage. writeBodyBufferString(String string)Overridden fromMessageto enable fluent APIMethods in org.apache.activemq.artemis.api.core.client with parameters of type ClientMessage Modifier and Type Method Description voidMessageHandler. onMessage(ClientMessage message)Notifies the MessageHandler that a message has been received.ClientMessageClientRequestor. request(ClientMessage request)Sends a message to the request address and wait indefinitely for a reply.ClientMessageClientRequestor. request(ClientMessage request, long timeout)Sends a message to the request address and wait for the given timeout for a reply. -
Uses of ClientMessage in org.apache.activemq.artemis.cli.commands
Method parameters in org.apache.activemq.artemis.cli.commands with type arguments of type ClientMessage Modifier and Type Method Description voidAbstractAction. performCoreManagement(AbstractAction.ManagementCallback<ClientMessage> cb) -
Uses of ClientMessage in org.apache.activemq.artemis.core.client.impl
Subinterfaces of ClientMessage in org.apache.activemq.artemis.core.client.impl Modifier and Type Interface Description interfaceClientLargeMessageInternalinterfaceClientMessageInternalClasses in org.apache.activemq.artemis.core.client.impl that implement ClientMessage Modifier and Type Class Description classClientLargeMessageImplClientLargeMessageImpl is only created when receiving large messages.classClientMessageImplA ClientMessageImplMethods in org.apache.activemq.artemis.core.client.impl that return ClientMessage Modifier and Type Method Description ClientMessageClientSessionImpl. createMessage(boolean durable)ClientMessageClientSessionImpl. createMessage(byte type, boolean durable)ClientMessageClientSessionImpl. createMessage(byte type, boolean durable, long expiration, long timestamp, byte priority)ClientMessageClientConsumerImpl. receive()ClientMessageClientConsumerImpl. receive(long timeout)ClientMessageClientConsumerImpl. receiveImmediate()Methods in org.apache.activemq.artemis.core.client.impl with parameters of type ClientMessage Modifier and Type Method Description voidClientConsumerImpl. acknowledge(ClientMessage message)voidClientConsumerInternal. acknowledge(ClientMessage message)voidClientConsumerImpl. individualAcknowledge(ClientMessage message)voidClientConsumerInternal. individualAcknowledge(ClientMessage message) -
Uses of ClientMessage in org.apache.activemq.artemis.core.server.federation
Methods in org.apache.activemq.artemis.core.server.federation with parameters of type ClientMessage Modifier and Type Method Description voidFederatedQueueConsumerImpl. onMessage(ClientMessage clientMessage) -
Uses of ClientMessage in org.apache.activemq.artemis.jms.client
Fields in org.apache.activemq.artemis.jms.client declared as ClientMessage Modifier and Type Field Description protected ClientMessageActiveMQMessage. messageMethods in org.apache.activemq.artemis.jms.client that return ClientMessage Modifier and Type Method Description ClientMessageActiveMQMessage. getCoreMessage()Methods in org.apache.activemq.artemis.jms.client with parameters of type ClientMessage Modifier and Type Method Description static ActiveMQMessageActiveMQMessage. createMessage(ClientMessage message, ClientSession session)static ActiveMQMessageActiveMQMessage. createMessage(ClientMessage message, ClientSession session, ConnectionFactoryOptions options)voidJMSMessageListenerWrapper. onMessage(ClientMessage message)In this method we apply the JMS acknowledgement and redelivery semantics as per JMS specConstructors in org.apache.activemq.artemis.jms.client with parameters of type ClientMessage Constructor Description ActiveMQBytesMessage(ClientMessage message, ClientSession session)Constructor on receipt at client sideActiveMQMapMessage(ClientMessage message, ClientSession session)ActiveMQMessage(ClientMessage message, ClientSession session)Constructor for when receiving a message from the serverActiveMQObjectMessage(ClientMessage message, ClientSession session, ConnectionFactoryOptions options)ActiveMQStreamMessage(ClientMessage message, ClientSession session)ActiveMQTextMessage(ClientMessage message, ClientSession session) -
Uses of ClientMessage in org.apache.activemq.artemis.jms.client.compatible1X
Methods in org.apache.activemq.artemis.jms.client.compatible1X with parameters of type ClientMessage Modifier and Type Method Description static ActiveMQMessageActiveMQCompatibleMessage. createMessage(ClientMessage message, ClientSession session, ConnectionFactoryOptions options)Constructors in org.apache.activemq.artemis.jms.client.compatible1X with parameters of type ClientMessage Constructor Description ActiveMQBytesCompatibleMessage(ClientMessage message, ClientSession session)ActiveMQCompatibleMessage(ClientMessage message, ClientSession session)ActiveMQMapCompatibleMessage(ClientMessage message, ClientSession session)ActiveMQObjectCompatibleMessage(ClientMessage message, ClientSession session, ConnectionFactoryOptions options)ActiveMQStreamCompatibleMessage(ClientMessage message, ClientSession session)ActiveMQTextCompatibleMessage(ClientMessage message, ClientSession session)
-