A B C D E F G H I L M O P R S T V

A

AbstractBasicMessageListener<T extends BasicMessage> - Class in org.hawkular.bus.common.consumer

A message listener that expects to receive a JSON-encoded BasicMessage or one of its subclasses; the JSON decoding is handled for you.

AbstractBasicMessageListener() - Constructor for class org.hawkular.bus.common.consumer.AbstractBasicMessageListener

AbstractBasicMessageListener(Class<T>) - Constructor for class org.hawkular.bus.common.consumer.AbstractBasicMessageListener

If a subclass knows the type and can give it to us, that will be the type used to decode JSON strings into that message type.

AbstractBasicMessageListener(ClassLoader) - Constructor for class org.hawkular.bus.common.consumer.AbstractBasicMessageListener

A special constructor to be used when the desarialization should be based on the class name supplied in MessageProcessor.HEADER_BASIC_MESSAGE_CLASS string property of Message.

AbstractMessage - Class in org.hawkular.bus.common

Basic information that is sent over the message bus.

AbstractMessage() - Constructor for class org.hawkular.bus.common.AbstractMessage

available() - Method in class org.hawkular.bus.common.BinaryData

B

BasicMessage - Interface in org.hawkular.bus.common

BasicMessageListener<T extends BasicMessage> - Class in org.hawkular.bus.common.consumer

A message listener that expects to receive a JSON-encoded BasicMessage or one of its subclasses.

BasicMessageListener() - Constructor for class org.hawkular.bus.common.consumer.BasicMessageListener

BasicMessageListener(Class<T>) - Constructor for class org.hawkular.bus.common.consumer.BasicMessageListener

BasicMessageListener(ClassLoader) - Constructor for class org.hawkular.bus.common.consumer.BasicMessageListener

BasicMessageWithExtraData<T extends BasicMessage> - Class in org.hawkular.bus.common

Just a simple container that contains a AbstractMessage and some (optional) binary data associated with the message.

BasicMessageWithExtraData(T, BinaryData) - Constructor for class org.hawkular.bus.common.BasicMessageWithExtraData

BinaryData - Class in org.hawkular.bus.common

This is a stream that is backed either by the provided InputStream or by a SequenceInputStream, should the inMemoryData be provided.

BinaryData(byte[], InputStream) - Constructor for class org.hawkular.bus.common.BinaryData

buildObjectMapperForDeserialization() - Static method in class org.hawkular.bus.common.AbstractMessage

This is static, so really there is no true overriding it in subclasses.

buildObjectMapperForSerialization() - Method in class org.hawkular.bus.common.AbstractMessage

Bus - Class in org.hawkular.bus.common

Bus() - Constructor for class org.hawkular.bus.common.Bus

BytesMessageInputStream - Class in org.hawkular.bus.common.consumer

BytesMessageInputStream(BytesMessage) - Constructor for class org.hawkular.bus.common.consumer.BytesMessageInputStream

C

cacheConnection(Connection, boolean) - Method in class org.hawkular.bus.common.ConnectionContextFactory

To store a connection in this processor object, call this setter.

close() - Method in class org.hawkular.bus.common.BinaryData

close() - Method in class org.hawkular.bus.common.ConnectionContext

close() - Method in class org.hawkular.bus.common.ConnectionContextFactory

This will close its open connection that it has cached, thus freeing up resources.

close() - Method in class org.hawkular.bus.common.consumer.ConsumerConnectionContext

close() - Method in class org.hawkular.bus.common.producer.ProducerConnectionContext

ConnectionContext - Class in org.hawkular.bus.common

This is a simple POJO that just contains objects related to particular connection.

ConnectionContext() - Constructor for class org.hawkular.bus.common.ConnectionContext

ConnectionContextFactory - Class in org.hawkular.bus.common

Provides convenience functionality to create producer or consumer contexts.

ConnectionContextFactory(ConnectionFactory) - Constructor for class org.hawkular.bus.common.ConnectionContextFactory

Initializes with the given factory.

ConnectionContextFactory(boolean, ConnectionFactory) - Constructor for class org.hawkular.bus.common.ConnectionContextFactory

Initializes with the given factory.

connectionFactory - Variable in class org.hawkular.bus.common.ConnectionContextFactory

ConsumerConnectionContext - Class in org.hawkular.bus.common.consumer

ConsumerConnectionContext() - Constructor for class org.hawkular.bus.common.consumer.ConsumerConnectionContext

convertReceivedMessageClassNameToDesiredMessageClassName(String) - Method in class org.hawkular.bus.common.consumer.AbstractBasicMessageListener

This allows subclasses to name a different JSON POJO implementation to use when deserializing incoming JSON.

copy(ConnectionContext) - Method in class org.hawkular.bus.common.ConnectionContext

Sets this context object with the same data found in the source context.

createConnection(ConnectionContext) - Method in class org.hawkular.bus.common.ConnectionContextFactory

Creates a connection using this object's connection factory and stores that connection in the given context object.

createConsumer(ConsumerConnectionContext, String) - Method in class org.hawkular.bus.common.ConnectionContextFactory

Creates a message consumer using the context's session and destination.

createConsumerConnectionContext(Endpoint) - Method in class org.hawkular.bus.common.ConnectionContextFactory

Creates a new consumer connection context, reusing any existing connection that might have already been created.

createConsumerConnectionContext(Endpoint, String) - Method in class org.hawkular.bus.common.ConnectionContextFactory

Creates a new consumer connection context, reusing any existing connection that might have already been created.

createDestination(ConnectionContext, Endpoint) - Method in class org.hawkular.bus.common.ConnectionContextFactory

Creates a destination using the context's session.

createMessage(ConnectionContext, BasicMessage) - Method in class org.hawkular.bus.common.MessageProcessor

Same as MessageProcessor.createMessage(ConnectionContext, BasicMessage, Map) with null headers.

createMessage(ConnectionContext, BasicMessage, Map<String, String>) - Method in class org.hawkular.bus.common.MessageProcessor

Creates a text message that can be send via a producer that contains the given BasicMessage's JSON encoded data.

createMessageWithBinaryData(ConnectionContext, BasicMessage, InputStream) - Method in class org.hawkular.bus.common.MessageProcessor

Same as MessageProcessor.createMessage(ConnectionContext, BasicMessage, Map) with null headers.

createMessageWithBinaryData(ConnectionContext, BasicMessage, InputStream, Map<String, String>) - Method in class org.hawkular.bus.common.MessageProcessor

Creates a blob message that can be send via a producer that contains the given BasicMessage's JSON encoded data along with binary data.

createOrReuseConnection(ConnectionContext, boolean) - Method in class org.hawkular.bus.common.ConnectionContextFactory

This method provides a way to cache and share a connection across multiple contexts.

createProducer(ProducerConnectionContext) - Method in class org.hawkular.bus.common.ConnectionContextFactory

Creates a message producer using the context's session and destination.

createProducerConnectionContext(Endpoint) - Method in class org.hawkular.bus.common.ConnectionContextFactory

Creates a new producer connection context, reusing any existing connection that might have already been created.

createSession(ConnectionContext) - Method in class org.hawkular.bus.common.ConnectionContextFactory

Creates a default session using the context's connection.

D

determineBasicMessageClass() - Method in class org.hawkular.bus.common.consumer.AbstractBasicMessageListener

In order to decode the JSON, we need the class representation of the basic message type.

E

Endpoint - Class in org.hawkular.bus.common

POJO that indicates the type of endpoint (queue or topic) and that queue or topic's name.

Endpoint(String) - Constructor for class org.hawkular.bus.common.Endpoint

An endpoint as specified in URI format: "type://name"

Endpoint(Endpoint.Type, String) - Constructor for class org.hawkular.bus.common.Endpoint

Endpoint(Endpoint.Type, String, boolean) - Constructor for class org.hawkular.bus.common.Endpoint

Endpoint.Type - Enum in org.hawkular.bus.common

equals(Object) - Method in class org.hawkular.bus.common.Endpoint

equals(Object) - Method in class org.hawkular.bus.common.MessageId

errorCannotCancelRunningFuture() - Method in interface org.hawkular.bus.common.log.MsgLogger

errorCannotCancelRunningFuture() - Method in class org.hawkular.bus.common.log.MsgLogger_$logger

errorCannotCancelRunningFuture$str() - Method in class org.hawkular.bus.common.log.MsgLogger_$logger

errorCannotCloseConnectionMemoryMightLeak(Throwable) - Method in interface org.hawkular.bus.common.log.MsgLogger

errorCannotCloseConnectionMemoryMightLeak(Throwable) - Method in class org.hawkular.bus.common.log.MsgLogger_$logger

errorCannotCloseConnectionMemoryMightLeak$str() - Method in class org.hawkular.bus.common.log.MsgLogger_$logger

errorCannotStoreIncomingMessageFutureInvalid() - Method in interface org.hawkular.bus.common.log.MsgLogger

errorCannotStoreIncomingMessageFutureInvalid() - Method in class org.hawkular.bus.common.log.MsgLogger_$logger

errorCannotStoreIncomingMessageFutureInvalid$str() - Method in class org.hawkular.bus.common.log.MsgLogger_$logger

errorConsumerCloseFailureOnFutureCancel() - Method in interface org.hawkular.bus.common.log.MsgLogger

errorConsumerCloseFailureOnFutureCancel() - Method in class org.hawkular.bus.common.log.MsgLogger_$logger

errorConsumerCloseFailureOnFutureCancel$str() - Method in class org.hawkular.bus.common.log.MsgLogger_$logger

errorFailedToCloseFutureConsumer(Throwable) - Method in interface org.hawkular.bus.common.log.MsgLogger

errorFailedToCloseFutureConsumer(Throwable) - Method in class org.hawkular.bus.common.log.MsgLogger_$logger

errorFailedToCloseFutureConsumer$str() - Method in class org.hawkular.bus.common.log.MsgLogger_$logger

errorFailedToCloseResourcesToRPCClient(Throwable) - Method in interface org.hawkular.bus.common.log.MsgLogger

errorFailedToCloseResourcesToRPCClient(Throwable) - Method in class org.hawkular.bus.common.log.MsgLogger_$logger

errorFailedToCloseResourcesToRPCClient$str() - Method in class org.hawkular.bus.common.log.MsgLogger_$logger

errorFailedToSendResponse(Throwable) - Method in interface org.hawkular.bus.common.log.MsgLogger

errorFailedToSendResponse(Throwable) - Method in class org.hawkular.bus.common.log.MsgLogger_$logger

errorFailedToSendResponse$str() - Method in class org.hawkular.bus.common.log.MsgLogger_$logger

errorFailedToStartConnection(Throwable) - Method in interface org.hawkular.bus.common.log.MsgLogger

errorFailedToStartConnection(Throwable) - Method in class org.hawkular.bus.common.log.MsgLogger_$logger

errorFailedToStartConnection$str() - Method in class org.hawkular.bus.common.log.MsgLogger_$logger

errorNoConnectionContextInListener() - Method in interface org.hawkular.bus.common.log.MsgLogger

errorNoConnectionContextInListener() - Method in class org.hawkular.bus.common.log.MsgLogger_$logger

errorNoConnectionContextInListener$str() - Method in class org.hawkular.bus.common.log.MsgLogger_$logger

errorNoMessageSenderInListener() - Method in interface org.hawkular.bus.common.log.MsgLogger

errorNoMessageSenderInListener() - Method in class org.hawkular.bus.common.log.MsgLogger_$logger

errorNoMessageSenderInListener$str() - Method in class org.hawkular.bus.common.log.MsgLogger_$logger

errorNoSessionInListener() - Method in interface org.hawkular.bus.common.log.MsgLogger

errorNoSessionInListener() - Method in class org.hawkular.bus.common.log.MsgLogger_$logger

errorNoSessionInListener$str() - Method in class org.hawkular.bus.common.log.MsgLogger_$logger

errorNotValidJsonMessage(Throwable) - Method in interface org.hawkular.bus.common.log.MsgLogger

errorNotValidJsonMessage(Throwable) - Method in class org.hawkular.bus.common.log.MsgLogger_$logger

errorNotValidJsonMessage$str() - Method in class org.hawkular.bus.common.log.MsgLogger_$logger

errorNotValidTextMessage(Throwable) - Method in interface org.hawkular.bus.common.log.MsgLogger

errorNotValidTextMessage(Throwable) - Method in class org.hawkular.bus.common.log.MsgLogger_$logger

errorNotValidTextMessage$str() - Method in class org.hawkular.bus.common.log.MsgLogger_$logger

F

FailOnUnknownProperties - Interface in org.hawkular.bus.common.msg.features

A marker interface for message classes whose deserialization should fail in case of unknown properties.

fromJSON(String, Class<T>) - Static method in class org.hawkular.bus.common.AbstractMessage

Convenience static method that converts a JSON string to a particular message object.

fromJSON(InputStream, Class<T>) - Static method in class org.hawkular.bus.common.AbstractMessage

Convenience static method that reads a JSON string from the given stream and converts the JSON string to a particular message object.

G

getBasicMessage() - Method in class org.hawkular.bus.common.BasicMessageWithExtraData

getBasicMessageClass() - Method in class org.hawkular.bus.common.consumer.AbstractBasicMessageListener

getBinaryData() - Method in class org.hawkular.bus.common.BasicMessageWithExtraData

getConnection() - Method in class org.hawkular.bus.common.ConnectionContext

getConnection() - Method in class org.hawkular.bus.common.ConnectionContextFactory

The stored connection.

getConnectionFactory() - Method in class org.hawkular.bus.common.ConnectionContextFactory

getConsumerConnectionContext() - Method in class org.hawkular.bus.common.consumer.AbstractBasicMessageListener

When this listener is attached to a consumer, this field should be filled in to allow the listener to perform other tasks it needs which might require access to the context.

getCorrelationId() - Method in class org.hawkular.bus.common.AbstractMessage

If this message is correlated with another message, this will be that other message's ID.

getCorrelationId() - Method in interface org.hawkular.bus.common.BasicMessage

getDestination() - Method in class org.hawkular.bus.common.ConnectionContext

getDetails() - Method in class org.hawkular.bus.common.SimpleBasicMessage

Optional additional details about this message.

getHeaders() - Method in class org.hawkular.bus.common.AbstractMessage

The headers that were shipped along side of the message when the message was received.

getHeaders() - Method in interface org.hawkular.bus.common.BasicMessage

getId() - Method in class org.hawkular.bus.common.MessageId

getLog() - Method in class org.hawkular.bus.common.consumer.AbstractBasicMessageListener

getMessage() - Method in class org.hawkular.bus.common.ObjectMessage

The simple JSON representation of the object.

getMessage() - Method in class org.hawkular.bus.common.SimpleBasicMessage

The simple message string of this message.

getMessageConsumer() - Method in class org.hawkular.bus.common.consumer.ConsumerConnectionContext

getMessageId() - Method in class org.hawkular.bus.common.AbstractMessage

Returns the message ID that was assigned to this message by the messaging infrastructure.

getMessageId() - Method in interface org.hawkular.bus.common.BasicMessage

getMessageProducer() - Method in class org.hawkular.bus.common.producer.ProducerConnectionContext

getMessageSender() - Method in class org.hawkular.bus.common.consumer.RPCBasicMessageListener

getName() - Method in class org.hawkular.bus.common.Endpoint

getObject() - Method in class org.hawkular.bus.common.ObjectMessage

getObjectClass() - Method in class org.hawkular.bus.common.ObjectMessage

getRequestMessage() - Method in class org.hawkular.bus.common.consumer.RPCConnectionContext

This is the request message that was sent.

getResponseListener() - Method in class org.hawkular.bus.common.consumer.RPCConnectionContext

This is the listener that is assigned to process the returned response.

getSession() - Method in class org.hawkular.bus.common.ConnectionContext

getType() - Method in class org.hawkular.bus.common.Endpoint

H

hashCode() - Method in class org.hawkular.bus.common.Endpoint

hashCode() - Method in class org.hawkular.bus.common.MessageId

HEADER_BASIC_MESSAGE_CLASS - Static variable in class org.hawkular.bus.common.MessageProcessor

I

isReuseConnection() - Method in class org.hawkular.bus.common.ConnectionContextFactory

isTemporary() - Method in class org.hawkular.bus.common.Endpoint

L

listen(ConsumerConnectionContext, AbstractBasicMessageListener<T>) - Method in class org.hawkular.bus.common.MessageProcessor

Listens for messages.

LOGGER - Static variable in interface org.hawkular.bus.common.log.MsgLogger

M

mark(int) - Method in class org.hawkular.bus.common.BinaryData

markSupported() - Method in class org.hawkular.bus.common.BinaryData

MessageId - Class in org.hawkular.bus.common

Identifies a message that has been sent over the message bus.

MessageId() - Constructor for class org.hawkular.bus.common.MessageId

MessageId(String) - Constructor for class org.hawkular.bus.common.MessageId

MessageProcessor - Class in org.hawkular.bus.common

Provides some functionality to process messages, both as a producer or consumer.

MessageProcessor() - Constructor for class org.hawkular.bus.common.MessageProcessor

MsgLogger - Interface in org.hawkular.bus.common.log

MsgLogger_$logger - Class in org.hawkular.bus.common.log

Warning this class consists of generated code.

MsgLogger_$logger(Logger) - Constructor for class org.hawkular.bus.common.log.MsgLogger_$logger

O

ObjectMessage - Class in org.hawkular.bus.common

A message that contains a complex object, which gets serialized into JSON.

ObjectMessage() - Constructor for class org.hawkular.bus.common.ObjectMessage

ObjectMessage(Object) - Constructor for class org.hawkular.bus.common.ObjectMessage

ObjectMessage(Class<?>) - Constructor for class org.hawkular.bus.common.ObjectMessage

onBasicMessage(BasicMessageWithExtraData<T>) - Method in class org.hawkular.bus.common.consumer.BasicMessageListener

Subclasses implement this method to process the received message.

onBasicMessage(T) - Method in class org.hawkular.bus.common.consumer.BasicMessageListener

Subclasses can implement this method rather than BasicMessageListener.onBasicMessage(BasicMessageWithExtraData) if they only expect to receive a BasicMessage with no additional data.

onBasicMessage(BasicMessageWithExtraData<T>) - Method in class org.hawkular.bus.common.consumer.RPCBasicMessageListener

Subclasses implement this method to process the received message.

onBasicMessage(T) - Method in class org.hawkular.bus.common.consumer.RPCBasicMessageListener

Subclasses can implement this method rather than RPCBasicMessageListener.onBasicMessage(BasicMessageWithExtraData) if they only expect to receive a AbstractMessage with no additional data.

onMessage(Message) - Method in class org.hawkular.bus.common.consumer.BasicMessageListener

onMessage(Message) - Method in class org.hawkular.bus.common.consumer.RPCBasicMessageListener

org.hawkular.bus.common - package org.hawkular.bus.common

org.hawkular.bus.common.consumer - package org.hawkular.bus.common.consumer

org.hawkular.bus.common.log - package org.hawkular.bus.common.log

org.hawkular.bus.common.msg.features - package org.hawkular.bus.common.msg.features

org.hawkular.bus.common.producer - package org.hawkular.bus.common.producer

P

parseMessage(Message) - Method in class org.hawkular.bus.common.consumer.AbstractBasicMessageListener

Given the BasicMessage received over the wire, convert it to our T representation of the message and keep any extra data that came with it.

ProducerConnectionContext - Class in org.hawkular.bus.common.producer

ProducerConnectionContext() - Constructor for class org.hawkular.bus.common.producer.ProducerConnectionContext

R

read() - Method in class org.hawkular.bus.common.BinaryData

read(byte[]) - Method in class org.hawkular.bus.common.BinaryData

read(byte[], int, int) - Method in class org.hawkular.bus.common.BinaryData

read() - Method in class org.hawkular.bus.common.consumer.BytesMessageInputStream

read(byte[]) - Method in class org.hawkular.bus.common.consumer.BytesMessageInputStream

read(byte[], int, int) - Method in class org.hawkular.bus.common.consumer.BytesMessageInputStream

reset() - Method in class org.hawkular.bus.common.BinaryData

RPCBasicMessageListener<T extends BasicMessage,U extends BasicMessage> - Class in org.hawkular.bus.common.consumer

A listener that processes an incoming request that will require a response sent back to the sender of the request.

RPCBasicMessageListener() - Constructor for class org.hawkular.bus.common.consumer.RPCBasicMessageListener

Initialize with a default message sender.

RPCBasicMessageListener(MessageProcessor) - Constructor for class org.hawkular.bus.common.consumer.RPCBasicMessageListener

RPCBasicMessageListener(Class<T>) - Constructor for class org.hawkular.bus.common.consumer.RPCBasicMessageListener

RPCBasicMessageListener(Class<T>, MessageProcessor) - Constructor for class org.hawkular.bus.common.consumer.RPCBasicMessageListener

RPCConnectionContext - Class in org.hawkular.bus.common.consumer

This is a context that will be associated with an incoming RPC call (that is, a request is sent and a response is expected back; mimicing an RPC call).

RPCConnectionContext() - Constructor for class org.hawkular.bus.common.consumer.RPCConnectionContext

S

send(String) - Method in class org.hawkular.bus.common.Bus

send(Destination, T) - Method in class org.hawkular.bus.common.Bus

send(ProducerConnectionContext, BasicMessage) - Method in class org.hawkular.bus.common.MessageProcessor

Same as MessageProcessor.send(ProducerConnectionContext, BasicMessage, Map) with null headers.

send(ProducerConnectionContext, BasicMessage, Map<String, String>) - Method in class org.hawkular.bus.common.MessageProcessor

Send the given message to its destinations across the message bus.

send(ProducerConnectionContext, BasicMessageWithExtraData<T>, Map<String, String>) - Method in class org.hawkular.bus.common.MessageProcessor

If the given message.getBinaryData() is not null delegates to MessageProcessor.sendWithBinaryData(ProducerConnectionContext, BasicMessage, InputStream, Map) otherwise delegates to MessageProcessor.send(ProducerConnectionContext, BasicMessageWithExtraData, Map)

sendAndListen(ProducerConnectionContext, BasicMessage, BasicMessageListener<T>) - Method in class org.hawkular.bus.common.MessageProcessor

Same as MessageProcessor.sendAndListen(ProducerConnectionContext, BasicMessage, BasicMessageListener, Map) with null headers.

sendAndListen(ProducerConnectionContext, BasicMessage, BasicMessageListener<T>, Map<String, String>) - Method in class org.hawkular.bus.common.MessageProcessor

Send the given message to its destinations across the message bus and any response sent back will be passed to the given listener.

sendWithBinaryData(ProducerConnectionContext, BasicMessage, InputStream) - Method in class org.hawkular.bus.common.MessageProcessor

Same as MessageProcessor.sendWithBinaryData(ProducerConnectionContext, BasicMessage, InputStream, Map) with null headers.

sendWithBinaryData(ProducerConnectionContext, BasicMessage, File) - Method in class org.hawkular.bus.common.MessageProcessor

Same as MessageProcessor.sendWithBinaryData(ProducerConnectionContext, BasicMessage, File, Map) with null headers.

sendWithBinaryData(ProducerConnectionContext, BasicMessage, File, Map<String, String>) - Method in class org.hawkular.bus.common.MessageProcessor

Same as MessageProcessor.sendWithBinaryData(ProducerConnectionContext, BasicMessage, InputStream, Map) with the input stream being a stream to read the file.

sendWithBinaryData(ProducerConnectionContext, BasicMessage, InputStream, Map<String, String>) - Method in class org.hawkular.bus.common.MessageProcessor

Send the given message along with the stream of binary data to its destinations across the message bus.

setConnection(Connection) - Method in class org.hawkular.bus.common.ConnectionContext

setConsumerConnectionContext(ConsumerConnectionContext) - Method in class org.hawkular.bus.common.consumer.AbstractBasicMessageListener

setCorrelationId(MessageId) - Method in class org.hawkular.bus.common.AbstractMessage

setCorrelationId(MessageId) - Method in interface org.hawkular.bus.common.BasicMessage

setDestination(Destination) - Method in class org.hawkular.bus.common.ConnectionContext

setHeaders(Map<String, String>) - Method in class org.hawkular.bus.common.AbstractMessage

Sets headers that will be sent with the message when the message gets delivered.

setHeaders(Map<String, String>) - Method in interface org.hawkular.bus.common.BasicMessage

setHeaders(BasicMessage, Map<String, String>, Message) - Method in class org.hawkular.bus.common.MessageProcessor

First sets the MessageProcessor.HEADER_BASIC_MESSAGE_CLASS string property of destination to basicMessage.getClass().getName(), then copies all headers from basicMessage.getHeaders() to destination using Message.setStringProperty(String, String) and then does the same thing with the supplied headers.

setMessage(String) - Method in class org.hawkular.bus.common.ObjectMessage

setMessage(String) - Method in class org.hawkular.bus.common.SimpleBasicMessage

Allow subclasses to set the message

setMessageConsumer(MessageConsumer) - Method in class org.hawkular.bus.common.consumer.ConsumerConnectionContext

setMessageId(MessageId) - Method in class org.hawkular.bus.common.AbstractMessage

setMessageId(MessageId) - Method in interface org.hawkular.bus.common.BasicMessage

setMessageProducer(MessageProducer) - Method in class org.hawkular.bus.common.producer.ProducerConnectionContext

setMessageSender(MessageProcessor) - Method in class org.hawkular.bus.common.consumer.RPCBasicMessageListener

setObjectClass(Class<?>) - Method in class org.hawkular.bus.common.ObjectMessage

setOnCloseAction(Runnable) - Method in class org.hawkular.bus.common.BinaryData

Provides custom action to run after BinaryData.close() finishes closing the stream.

setRequestMessage(Message) - Method in class org.hawkular.bus.common.consumer.RPCConnectionContext

setResponseListener(BasicMessageListener<?>) - Method in class org.hawkular.bus.common.consumer.RPCConnectionContext

setSession(Session) - Method in class org.hawkular.bus.common.ConnectionContext

SimpleBasicMessage - Class in org.hawkular.bus.common

A simple message that is sent over the message bus.

SimpleBasicMessage() - Constructor for class org.hawkular.bus.common.SimpleBasicMessage

SimpleBasicMessage(String) - Constructor for class org.hawkular.bus.common.SimpleBasicMessage

SimpleBasicMessage(String, Map<String, String>) - Constructor for class org.hawkular.bus.common.SimpleBasicMessage

skip(long) - Method in class org.hawkular.bus.common.BinaryData

T

TEMPORARY_QUEUE - Static variable in class org.hawkular.bus.common.Endpoint

TEMPORARY_TOPIC - Static variable in class org.hawkular.bus.common.Endpoint

toJSON() - Method in class org.hawkular.bus.common.AbstractMessage

Converts this message to its JSON string representation.

toJSON() - Method in interface org.hawkular.bus.common.BasicMessage

toString() - Method in class org.hawkular.bus.common.AbstractMessage

toString() - Method in class org.hawkular.bus.common.Endpoint

toString() - Method in class org.hawkular.bus.common.MessageId

V

valueOf(String) - Static method in enum org.hawkular.bus.common.Endpoint.Type

Returns the enum constant of this type with the specified name.

values() - Static method in enum org.hawkular.bus.common.Endpoint.Type

Returns an array containing the constants of this enum type, in the order they are declared.

A B C D E F G H I L M O P R S T V