public class FileSystemTransporter extends Transporter
ServiceBroker broker = ServiceBroker.builder().nodeID("node1")
.transporter(new FileSystemTransporter("/temp")).build();
| Modifier and Type | Class and Description |
|---|---|
protected static class |
FileSystemTransporter.DirectoryHandler |
protected static class |
FileSystemTransporter.RemovableFile |
| Modifier and Type | Field and Description |
|---|---|
protected java.lang.String |
directory
Root directory of message files (eg.
|
protected long |
fileTimeout
Read timeout of request in MILLISECONDS (deleted request files after this
limit).
|
protected java.util.HashMap<java.lang.String,FileSystemTransporter.DirectoryHandler> |
inputDirectories |
protected java.util.HashMap<java.lang.String,FileSystemTransporter.DirectoryHandler> |
outputDirectories |
protected java.util.concurrent.ScheduledFuture<?> |
pollerProcess
Cancelable timer of poller/cleanup process
|
protected long |
pollingDelay
Poll period in MILLISECONDS.
|
protected int |
storedFileNames
Max stored file names (per channel).
|
protected java.util.concurrent.ScheduledFuture<?> |
timeoutProcess
Cancelable timer of poller/cleanup process
|
checkTimeoutTimer, counterTransporterPacketsReceivedBytes, counterTransporterPacketsReceivedTotal, counterTransporterPacketsSentBytes, counterTransporterPacketsSentTotal, debug, debugHeartbeats, disconnectChannel, discoverBroadcastChannel, discoverChannel, eventbus, eventChannel, executor, gaugeTransitConnected, heartbeatChannel, heartbeatInterval, heartbeatTimeout, heartBeatTimer, infoBroadcastChannel, infoChannel, infoScheduled, infoScheduledAt, instanceID, lastReceivedMessageAt, metrics, monitor, namespace, nodeID, nodes, offlineTimeout, PACKET_DISCONNECT, PACKET_DISCOVER, PACKET_EVENT, PACKET_HEARTBEAT, PACKET_INFO, PACKET_PING, PACKET_PONG, PACKET_REQUEST, PACKET_RESPONSE, pingChannel, pongChannel, preferHostname, prefix, protocolVersion, registry, requestChannel, responseChannel, scheduler, serializer, serviceInvoker, subscriptionTimeout, uidGenerator, usingJsonSerializerbroker, logger, nameMOLECULER_CACHER_CLEAN_TIME, MOLECULER_CACHER_CLEAN_TIME_DESC, MOLECULER_CACHER_CLEAN_TOTAL, MOLECULER_CACHER_CLEAN_TOTAL_DESC, MOLECULER_CACHER_DEL_TIME, MOLECULER_CACHER_DEL_TIME_DESC, MOLECULER_CACHER_DEL_TOTAL, MOLECULER_CACHER_DEL_TOTAL_DESC, MOLECULER_CACHER_EXPIRED_TOTAL, MOLECULER_CACHER_EXPIRED_TOTAL_DESC, MOLECULER_CACHER_FOUND_TOTAL, MOLECULER_CACHER_FOUND_TOTAL_DESC, MOLECULER_CACHER_GET_TIME, MOLECULER_CACHER_GET_TIME_DESC, MOLECULER_CACHER_GET_TOTAL, MOLECULER_CACHER_GET_TOTAL_DESC, MOLECULER_CACHER_SET_TIME, MOLECULER_CACHER_SET_TIME_DESC, MOLECULER_CACHER_SET_TOTAL, MOLECULER_CACHER_SET_TOTAL_DESC, MOLECULER_CIRCUIT_BREAKER_HALF_OPENED_ACTIVE, MOLECULER_CIRCUIT_BREAKER_HALF_OPENED_ACTIVE_DESC, MOLECULER_CIRCUIT_BREAKER_OPENED_ACTIVE, MOLECULER_CIRCUIT_BREAKER_OPENED_ACTIVE_DESC, MOLECULER_CIRCUIT_BREAKER_OPENED_TOTAL, MOLECULER_CIRCUIT_BREAKER_OPENED_TOTAL_DESC, MOLECULER_EVENT_BROADCAST_TOTAL, MOLECULER_EVENT_BROADCAST_TOTAL_DESC, MOLECULER_EVENT_BROADCASTLOCAL_TOTAL, MOLECULER_EVENT_BROADCASTLOCAL_TOTAL_DESC, MOLECULER_EVENT_EMIT_TOTAL, MOLECULER_EVENT_EMIT_TOTAL_DESC, MOLECULER_EVENT_RECEIVED_ACTIVE, MOLECULER_EVENT_RECEIVED_ACTIVE_DESC, MOLECULER_EVENT_RECEIVED_ERROR_TOTAL, MOLECULER_EVENT_RECEIVED_ERROR_TOTAL_DESC, MOLECULER_EVENT_RECEIVED_TIME, MOLECULER_EVENT_RECEIVED_TIME_DESC, MOLECULER_EVENT_RECEIVED_TOTAL, MOLECULER_EVENT_RECEIVED_TOTAL_DESC, MOLECULER_EXECUTOR, MOLECULER_REQUEST_ACTIVE, MOLECULER_REQUEST_ACTIVE_DESC, MOLECULER_REQUEST_ERROR_TOTAL, MOLECULER_REQUEST_ERROR_TOTAL_DESC, MOLECULER_REQUEST_LEVELS, MOLECULER_REQUEST_LEVELS_DESC, MOLECULER_REQUEST_RETRY_ATTEMPTS_TOTAL, MOLECULER_REQUEST_RETRY_ATTEMPTS_TOTAL_DESC, MOLECULER_REQUEST_TIME, MOLECULER_REQUEST_TIME_DESC, MOLECULER_REQUEST_TIMEOUT_TOTAL, MOLECULER_REQUEST_TIMEOUT_TOTAL_DESC, MOLECULER_REQUEST_TOTAL, MOLECULER_REQUEST_TOTAL_DESC, MOLECULER_SCHEDULER, MOLECULER_TRANSIT_CONNECTED, MOLECULER_TRANSIT_CONNECTED_DESC, MOLECULER_TRANSIT_ORPHAN_RESPONSE_TOTAL, MOLECULER_TRANSIT_ORPHAN_RESPONSE_TOTAL_DESC, MOLECULER_TRANSIT_REQUESTS_ACTIVE, MOLECULER_TRANSIT_REQUESTS_ACTIVE_DESC, MOLECULER_TRANSIT_STREAMS_RECEIVE_ACTIVE, MOLECULER_TRANSIT_STREAMS_RECEIVE_ACTIVE_DESC, MOLECULER_TRANSPORTER_PACKETS_RECEIVED_BYTES, MOLECULER_TRANSPORTER_PACKETS_RECEIVED_BYTES_DESC, MOLECULER_TRANSPORTER_PACKETS_RECEIVED_TOTAL, MOLECULER_TRANSPORTER_PACKETS_RECEIVED_TOTAL_DESC, MOLECULER_TRANSPORTER_PACKETS_SENT_BYTES, MOLECULER_TRANSPORTER_PACKETS_SENT_BYTES_DESC, MOLECULER_TRANSPORTER_PACKETS_SENT_TOTAL, MOLECULER_TRANSPORTER_PACKETS_SENT_TOTAL_DESC| Constructor and Description |
|---|
FileSystemTransporter() |
FileSystemTransporter(java.lang.String directory) |
FileSystemTransporter(java.lang.String directory,
long pollingDelay) |
| Modifier and Type | Method and Description |
|---|---|
void |
connect() |
protected java.io.File |
getChannelDirectory(java.lang.String channel) |
java.lang.String |
getDirectory() |
long |
getFileTimeout() |
long |
getPollingDelay() |
int |
getStoredFileNames() |
protected void |
pollerProcess() |
void |
publish(java.lang.String channel,
io.datatree.Tree message) |
void |
setDirectory(java.lang.String directory) |
void |
setFileTimeout(long fileTimeout) |
void |
setPollingDelay(long pollingDelay) |
void |
setStoredFileNames(int storedFileNames) |
void |
started(ServiceBroker broker)
Initializes transporter instance.
|
void |
stopped()
Closes transporter.
|
io.datatree.Promise |
subscribe(java.lang.String channel) |
protected void |
timeoutProcess() |
broadcastInfoPacket, broadcastNodeConnected, broadcastNodeDisconnected, broadcastNodeUpdated, broadcastTransporterConnected, broadcastTransporterDisconnected, channel, checkTimeouts, connected, connected, createPingPacket, error, getAddress, getAllNodeIDs, getCpuUsage, getDescriptor, getHeartbeatInterval, getHeartbeatTimeout, getInstanceID, getLastHeartbeatTime, getNamespace, getOfflineTimeout, getPrefix, getSerializer, getSubscriptionTimeout, isDebug, isDebugHeartbeats, isOnline, isPreferHostname, processReceivedMessage, processReceivedMessage, publish, received, scheduleInfoPacket, sendClosePacket, sendDataPacket, sendDisconnectPacket, sendDiscoverPacket, sendErrorPacket, sendEventPacket, sendHeartbeatPacket, sendInfoPacket, sendPongPacket, sendRequestPacket, setDebug, setDebugHeartbeats, setHeartbeatInterval, setHeartbeatTimeout, setNamespace, setOfflineTimeout, setPreferHostname, setPrefix, setSerializer, setSubscriptionTimeout, subscribe, updateNodeInfogetBroker, getLogger, getNameprotected java.lang.String directory
protected long pollingDelay
protected long fileTimeout
protected int storedFileNames
protected java.util.HashMap<java.lang.String,FileSystemTransporter.DirectoryHandler> inputDirectories
protected java.util.HashMap<java.lang.String,FileSystemTransporter.DirectoryHandler> outputDirectories
protected volatile java.util.concurrent.ScheduledFuture<?> pollerProcess
protected volatile java.util.concurrent.ScheduledFuture<?> timeoutProcess
public FileSystemTransporter()
public FileSystemTransporter(java.lang.String directory)
public FileSystemTransporter(java.lang.String directory,
long pollingDelay)
public void started(ServiceBroker broker) throws java.lang.Exception
Transporterstarted in interface MoleculerLifecyclestarted in class Transporterbroker - parent ServiceBrokerjava.lang.Exceptionpublic void stopped()
Transporterstopped in interface MoleculerLifecyclestopped in class Transporterprotected void pollerProcess()
protected void timeoutProcess()
public void connect()
connect in class Transporterpublic void publish(java.lang.String channel,
io.datatree.Tree message)
publish in class Transporterpublic io.datatree.Promise subscribe(java.lang.String channel)
subscribe in class Transporterprotected java.io.File getChannelDirectory(java.lang.String channel)
public java.lang.String getDirectory()
public void setDirectory(java.lang.String directory)
public long getPollingDelay()
public void setPollingDelay(long pollingDelay)
public long getFileTimeout()
public void setFileTimeout(long fileTimeout)
public int getStoredFileNames()
public void setStoredFileNames(int storedFileNames)