B C D E F G H I N P S T W
All Classes All Packages

B

BasicNatsConnection - Class in com.adaptris.interlok.nats

Basic Connection to a NATS server.

BasicNatsConnection() - Constructor for class com.adaptris.interlok.nats.BasicNatsConnection

build(Message, AdaptrisMessageFactory) - Static method in class com.adaptris.interlok.nats.Helper

Create an AdaptrisMessage from the incoming Message.

C

clientConnection() - Method in class com.adaptris.interlok.nats.NatsConnection

close(Dispatcher) - Method in class com.adaptris.interlok.nats.NatsConnection

closeConnection() - Method in class com.adaptris.interlok.nats.NatsConnection

closeDispatcher(Connection, Dispatcher) - Static method in class com.adaptris.interlok.nats.Helper

closeDispatchers(Connection, Collection<Dispatcher>) - Static method in class com.adaptris.interlok.nats.Helper

closeQuietly(AutoCloseable) - Static method in class com.adaptris.interlok.nats.Helper

com.adaptris.interlok.nats - package com.adaptris.interlok.nats

connect() - Method in class com.adaptris.interlok.nats.BasicNatsConnection

connect() - Method in class com.adaptris.interlok.nats.NatsConnection

connect() - Method in class com.adaptris.interlok.nats.NatsConnectionFromProperties

connectionName() - Method in class com.adaptris.interlok.nats.BasicNatsConnection

connectionName() - Method in class com.adaptris.interlok.nats.NatsConnection

connectionName() - Method in class com.adaptris.interlok.nats.NatsConnectionFromProperties

consumeLocationKey() - Method in class com.adaptris.interlok.nats.NatsConsumer

createDispatcher(MessageHandler) - Method in class com.adaptris.interlok.nats.NatsConnection

D

defaultTimeout() - Method in class com.adaptris.interlok.nats.NatsProducer

The default timeout if not specified is 60 seconds.

doProduce(AdaptrisMessage, String) - Method in class com.adaptris.interlok.nats.NatsProducer

doRequest(AdaptrisMessage, String, long) - Method in class com.adaptris.interlok.nats.NatsProducer

E

endpoint(AdaptrisMessage) - Method in class com.adaptris.interlok.nats.NatsProducer

exceedsMaxAttempts(int, T) - Method in class com.adaptris.interlok.nats.NatsConnection

F

findConnectionName(KeyValuePairSet) - Static method in class com.adaptris.interlok.nats.NatsConnectionFromProperties

G

getConnectionProperties() - Method in class com.adaptris.interlok.nats.NatsConnectionFromProperties

The connection properties.

getQueueGroup() - Method in class com.adaptris.interlok.nats.NatsConsumer

Specify the queue group for this consumer if it is required.

getSubject() - Method in class com.adaptris.interlok.nats.NatsConsumer

The Subject for the NATS subscription

getSubject() - Method in class com.adaptris.interlok.nats.NatsProducer

The NATS Subject

getUrl() - Method in class com.adaptris.interlok.nats.BasicNatsConnection

The URL to the nats server assuming that Nats#connect(String) is sufficient configuration for connecting to your NATS server.

H

Helper - Class in com.adaptris.interlok.nats

Helper for testability.

Helper() - Constructor for class com.adaptris.interlok.nats.Helper

I

initConnection() - Method in class com.adaptris.interlok.nats.NatsConnection

N

NATS_REPLY_TO - Static variable in interface com.adaptris.interlok.nats.NatsConstants

Metadata key that stores Message#getReplyTo(); value is "natsReplyTo".

NATS_SUBJECT - Static variable in interface com.adaptris.interlok.nats.NatsConstants

Metadata key that stores Message#getSubject(); value is "natsSubject".

NATS_SUBSCRIPTION_ID - Static variable in interface com.adaptris.interlok.nats.NatsConstants

Metadata key that stores Message#getSID(); value is "natsSubscriptionID".

NatsConnection - Class in com.adaptris.interlok.nats

NatsConnection() - Constructor for class com.adaptris.interlok.nats.NatsConnection

NatsConnectionFromProperties - Class in com.adaptris.interlok.nats

Connection to a NATS server.

NatsConnectionFromProperties() - Constructor for class com.adaptris.interlok.nats.NatsConnectionFromProperties

NatsConstants - Interface in com.adaptris.interlok.nats

NatsConsumer - Class in com.adaptris.interlok.nats

Consumer implementation for NATS.io.

NatsConsumer() - Constructor for class com.adaptris.interlok.nats.NatsConsumer

NatsProducer - Class in com.adaptris.interlok.nats

Produce the current message to a NATS server with the configured subject.

NatsProducer() - Constructor for class com.adaptris.interlok.nats.NatsProducer

newThreadName() - Method in class com.adaptris.interlok.nats.NatsConsumer

P

prepare() - Method in class com.adaptris.interlok.nats.NatsConsumer

prepare() - Method in class com.adaptris.interlok.nats.NatsProducer

prepareConnection() - Method in class com.adaptris.interlok.nats.BasicNatsConnection

prepareConnection() - Method in class com.adaptris.interlok.nats.NatsConnection

prepareConnection() - Method in class com.adaptris.interlok.nats.NatsConnectionFromProperties

S

setConnectionProperties(KeyValuePairSet) - Method in class com.adaptris.interlok.nats.NatsConnectionFromProperties

The connection properties.

setQueueGroup(String) - Method in class com.adaptris.interlok.nats.NatsConsumer

Specify the queue group for this consumer if it is required.

setSubject(String) - Method in class com.adaptris.interlok.nats.NatsConsumer

The Subject for the NATS subscription

setSubject(String) - Method in class com.adaptris.interlok.nats.NatsProducer

The NATS Subject

setUrl(String) - Method in class com.adaptris.interlok.nats.BasicNatsConnection

The URL to the nats server assuming that Nats#connect(String) is sufficient configuration for connecting to your NATS server.

start() - Method in class com.adaptris.interlok.nats.NatsConsumer

startConnection() - Method in class com.adaptris.interlok.nats.NatsConnection

stop() - Method in class com.adaptris.interlok.nats.NatsConsumer

stopConnection() - Method in class com.adaptris.interlok.nats.NatsConnection

T

toByteArray(AdaptrisMessage, long) - Method in class com.adaptris.interlok.nats.NatsProducer

W

withConnectionProperties(KeyValuePairSet) - Method in class com.adaptris.interlok.nats.NatsConnectionFromProperties

withConnectionRetries(int, TimeInterval) - Method in class com.adaptris.interlok.nats.NatsConnection

withQueueGroup(String) - Method in class com.adaptris.interlok.nats.NatsConsumer

withSubject(String) - Method in class com.adaptris.interlok.nats.NatsConsumer

withSubject(String) - Method in class com.adaptris.interlok.nats.NatsProducer

withUrl(String) - Method in class com.adaptris.interlok.nats.BasicNatsConnection

B C D E F G H I N P S T W
All Classes All Packages