C F G I M N O P R S U V

C

Connector - Class in io.nats.connector

This is the main connector class for the NATS Connector.

Connector(String[]) - Constructor for class io.nats.connector.Connector

Connector() - Constructor for class io.nats.connector.Connector

F

flush() - Method in interface io.nats.connector.plugin.NATSConnector

Flushes any pending NATS data.

G

getConnection() - Method in interface io.nats.connector.plugin.NATSConnector

Advanced API to get the NATS connection.

getConnectionFactory() - Method in interface io.nats.connector.plugin.NATSConnector

Advanced API to get the Connection Factory, This allows for NATS functionality beyond the interface here.

I

io.nats.connector - package io.nats.connector

io.nats.connector.plugin - package io.nats.connector.plugin

M

main(String[]) - Static method in class io.nats.connector.Connector

N

NATSConnector - Interface in io.nats.connector.plugin

Interface for the utility class passed to the plug-in, allowing additional NATS functionality such as publishing messsages and subscribing to subjects.

NATSConnectorPlugin - Interface in io.nats.connector.plugin

This interface that must be implemented for a NATS Connector plugin.

NATSEvent - Enum in io.nats.connector.plugin

Enumeration of NATSEvents passed to the plugin.

NATSUtilities - Class in io.nats.connector.plugin

Utilities used by the plugin.

NATSUtilities() - Constructor for class io.nats.connector.plugin.NATSUtilities

O

onNATSEvent(NATSEvent, String) - Method in interface io.nats.connector.plugin.NATSConnectorPlugin

Invoked anytime a NATS event occurs around a connection or error, alerting the plugin to take appropriate action.

onNatsInitialized(NATSConnector) - Method in interface io.nats.connector.plugin.NATSConnectorPlugin

Invoked after startup, when the NATS plug-in has connectivity to the NATS cluster, and is ready to start sending and and receiving messages.

onNATSMessage(Message) - Method in interface io.nats.connector.plugin.NATSConnectorPlugin

Invoked anytime a NATS message is received to be processed.

onShutdown() - Method in interface io.nats.connector.plugin.NATSConnectorPlugin

Invoked when the Plugin is shutting down.

onStartup(Logger, ConnectionFactory) - Method in interface io.nats.connector.plugin.NATSConnectorPlugin

Invoked when the connector is started up, before a connection to the NATS cluster is made.

P

PLUGIN_CLASS - Static variable in class io.nats.connector.Connector

Name of the property to set the plugin class name.

publish(Message) - Method in interface io.nats.connector.plugin.NATSConnector

Publishes a message into the NATS cluster.

R

readFromUrl(String) - Static method in class io.nats.connector.plugin.NATSUtilities

Reads a url and returns the content as a string.

run() - Method in class io.nats.connector.Connector

S

shutdown() - Method in class io.nats.connector.Connector

Shuts down a running Connector.

shutdown() - Method in interface io.nats.connector.plugin.NATSConnector

In case of a critical failure or security issue, this allows the plugin to request a shutdown of the connector.

subscribe(String) - Method in interface io.nats.connector.plugin.NATSConnector

Adds interest in a NATS subject.

subscribe(String, MessageHandler) - Method in interface io.nats.connector.plugin.NATSConnector

Adds interest in a NATS subject, with a custom handle.

subscribe(String, String) - Method in interface io.nats.connector.plugin.NATSConnector

Adds interest in a NATS subject with a queue group.

subscribe(String, String, MessageHandler) - Method in interface io.nats.connector.plugin.NATSConnector

Adds interest in a NATS subject with a queue group, with a custom handler.

U

unsubscribe(String) - Method in interface io.nats.connector.plugin.NATSConnector

Removes interest in a NATS subject

V

valueOf(String) - Static method in enum io.nats.connector.plugin.NATSEvent

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

values() - Static method in enum io.nats.connector.plugin.NATSEvent

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

C F G I M N O P R S U V