Index

A B C D E G H I M O P R S T U
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

ActiveMqConnectionFactory - Interface in org.kryonite.kryomessaging.api

B

bindQueueToExchange(String, String) - Method in interface org.kryonite.kryomessaging.api.MessagingService

Bind a queue to an existing exchange.

bindQueueToExchange(String, String) - Method in class org.kryonite.kryomessaging.service.DefaultMessagingService

bindQueueToExchange(String, String, String) - Method in interface org.kryonite.kryomessaging.api.MessagingService

Bind a queue to an exchange with a specific routing key.

bindQueueToExchange(String, String, String) - Method in class org.kryonite.kryomessaging.service.DefaultMessagingService

C

canEqual(Object) - Method in class org.kryonite.kryomessaging.service.message.InternalMessage

canEqual(Object) - Method in class org.kryonite.kryomessaging.service.message.Message

create() - Static method in class org.kryonite.kryomessaging.util.CustomObjectMapper

create(String, T) - Static method in class org.kryonite.kryomessaging.service.message.Message

create(String, T, String) - Static method in class org.kryonite.kryomessaging.service.message.Message

create(Message<T>, Map<String, Object>) - Static method in class org.kryonite.kryomessaging.service.message.InternalMessage

createConnection() - Method in interface org.kryonite.kryomessaging.api.ActiveMqConnectionFactory

createConnection() - Method in class org.kryonite.kryomessaging.service.DefaultActiveMqConnectionFactory

CustomObjectMapper - Class in org.kryonite.kryomessaging.util

CustomTypeResolver - Class in org.kryonite.kryomessaging.util

CustomTypeResolver() - Constructor for class org.kryonite.kryomessaging.util.CustomTypeResolver

D

DEFAULT_RETRY_COUNT - Static variable in class org.kryonite.kryomessaging.service.DefaultMessagingService

DefaultActiveMqConnectionFactory - Class in org.kryonite.kryomessaging.service

DefaultActiveMqConnectionFactory(List<Address>, String, String) - Constructor for class org.kryonite.kryomessaging.service.DefaultActiveMqConnectionFactory

DefaultMessagingService - Class in org.kryonite.kryomessaging.service

DefaultMessagingService(ActiveMqConnectionFactory) - Constructor for class org.kryonite.kryomessaging.service.DefaultMessagingService

E

equals(Object) - Method in class org.kryonite.kryomessaging.service.message.InternalMessage

equals(Object) - Method in class org.kryonite.kryomessaging.service.message.Message

G

getBody() - Method in class org.kryonite.kryomessaging.service.message.Message

getConnectionFactory() - Method in interface org.kryonite.kryomessaging.api.ActiveMqConnectionFactory

getConnectionFactory() - Method in class org.kryonite.kryomessaging.service.DefaultActiveMqConnectionFactory

getExchange() - Method in class org.kryonite.kryomessaging.service.message.Message

getHeaders() - Method in class org.kryonite.kryomessaging.service.message.InternalMessage

getMessage() - Method in class org.kryonite.kryomessaging.service.message.InternalMessage

getRoutingKey() - Method in class org.kryonite.kryomessaging.service.message.Message

H

hashCode() - Method in class org.kryonite.kryomessaging.service.message.InternalMessage

hashCode() - Method in class org.kryonite.kryomessaging.service.message.Message

I

InternalMessage<T> - Class in org.kryonite.kryomessaging.service.message

M

Message<T> - Class in org.kryonite.kryomessaging.service.message

MessageCallback<T> - Interface in org.kryonite.kryomessaging.service.message

messageReceived(Message<T>) - Method in interface org.kryonite.kryomessaging.service.message.MessageCallback

MessagingService - Interface in org.kryonite.kryomessaging.api

O

org.kryonite.kryomessaging.api - package org.kryonite.kryomessaging.api

org.kryonite.kryomessaging.service - package org.kryonite.kryomessaging.service

org.kryonite.kryomessaging.service.message - package org.kryonite.kryomessaging.service.message

org.kryonite.kryomessaging.util - package org.kryonite.kryomessaging.util

P

PublishMessageTask - Class in org.kryonite.kryomessaging.service.message

PublishMessageTask(Queue<InternalMessage<?>>, Channel) - Constructor for class org.kryonite.kryomessaging.service.message.PublishMessageTask

R

RETRY_HEADER - Static variable in class org.kryonite.kryomessaging.service.DefaultMessagingService

run() - Method in class org.kryonite.kryomessaging.service.message.PublishMessageTask

S

sendMessage(Message<?>) - Method in interface org.kryonite.kryomessaging.api.MessagingService

Send a message with any class as a payload.

sendMessage(Message<?>) - Method in class org.kryonite.kryomessaging.service.DefaultMessagingService

setRoutingKey(String) - Method in class org.kryonite.kryomessaging.service.message.Message

setupExchange(String, BuiltinExchangeType) - Method in interface org.kryonite.kryomessaging.api.MessagingService

Setup an exchange with a specific type and name.

setupExchange(String, BuiltinExchangeType) - Method in class org.kryonite.kryomessaging.service.DefaultMessagingService

startConsuming(String, MessageCallback<T>, Class<T>) - Method in interface org.kryonite.kryomessaging.api.MessagingService

Start consuming messages from a queue.

startConsuming(String, MessageCallback<T>, Class<T>) - Method in class org.kryonite.kryomessaging.service.DefaultMessagingService

T

toString() - Method in class org.kryonite.kryomessaging.service.message.InternalMessage

toString() - Method in class org.kryonite.kryomessaging.service.message.Message

U

useForType(JavaType) - Method in class org.kryonite.kryomessaging.util.CustomTypeResolver

A B C D E G H I M O P R S T U
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form