Package dev.getelements.elements.rt.remote.jeromq

Class JeroMQRoutingServer

java.lang.Object

dev.getelements.elements.rt.remote.jeromq.JeroMQRoutingServer

All Implemented Interfaces:

AutoCloseable

public class JeroMQRoutingServer
extends Object
implements AutoCloseable

Field Summary

Fields

Modifier and Type	Field	Description
static final Charset	CHARSET

Constructor Summary

Constructors

Constructor	Description
JeroMQRoutingServer(InstanceId instanceId, org.zeromq.ZContext zContext, List<String> bindAddresses, JeroMQSecurity securityChain)

Method Summary

Modifier and Type	Method	Description
void	close()
static org.zeromq.ZMsg	error(JeroMQControlResponseCode code, String message)
static org.zeromq.ZMsg	exceptionError(org.slf4j.Logger logger, JeroMQControlResponseCode code, Exception ex)
static org.zeromq.ZMsg	exceptionError(org.slf4j.Logger logger, Exception ex)
static org.slf4j.Logger	getLogger(Class<?> componentClass, InstanceId instanceId)
void	run(BooleanSupplier running)

Methods inherited from class java.lang.Object

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

Field Details

CHARSET

public static final Charset CHARSET

Constructor Details

JeroMQRoutingServer

public JeroMQRoutingServer(InstanceId instanceId,
 org.zeromq.ZContext zContext,
 List<String> bindAddresses,
 JeroMQSecurity securityChain)

Method Details

run

public void run(BooleanSupplier running)

close

public void close()

Specified by:

close in interface AutoCloseable

error

public static org.zeromq.ZMsg error(JeroMQControlResponseCode code,
 String message)

exceptionError

public static org.zeromq.ZMsg exceptionError(org.slf4j.Logger logger,
 Exception ex)

exceptionError

public static org.zeromq.ZMsg exceptionError(org.slf4j.Logger logger,
 JeroMQControlResponseCode code,
 Exception ex)

getLogger

public static org.slf4j.Logger getLogger(Class<?> componentClass,
 InstanceId instanceId)