io.nats.connector

Class Connector

java.lang.Object

io.nats.connector.Connector

All Implemented Interfaces:

Runnable

public class Connector
extends Object
implements Runnable

This is the main connector class for the NATS Connector.

It operates as follows:

The connector is entirely java properties driven - these can be set as parameters to the JVM or passed in as a file.

The Connector starts a thread which drives a DataFlowHandler. The handler connects to NATS and invokes various interfaces on a supplied plugin.

The plugin has a few APIs that allow it to publish messages, flush the NATS connection, and subscribe to various subjects.

A plugin can both subscribe to receive data and export it to another system, feed data into NATS, or both.

The plugin's responsibilities include: a) Ensuring performance out of nats. This may include some buffering if the destination of the data consumer slower than NATS produces it. b) Translation of external origin/destination and the subject namespace.

Field Summary

Fields

Modifier and Type	Field and Description
static String	PLUGIN_CLASS Name of the property to set the plugin class name.

Constructor Summary

Constructors

Constructor and Description
Connector()
Connector(String[] args)

Method Summary

Modifier and Type	Method and Description
static void	main(String[] args)
void	run()
void	shutdown() Shuts down a running Connector.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

PLUGIN_CLASS

public static final String PLUGIN_CLASS

Name of the property to set the plugin class name.

See Also:

Constant Field Values

Constructor Detail

Connector

public Connector(String[] args)
          throws Exception

Throws:

Exception

Connector

public Connector()
          throws Exception

Throws:

Exception

Method Detail

run

public void run()

Specified by:

run in interface Runnable

shutdown

public void shutdown()

Shuts down a running Connector.

main

public static void main(String[] args)