public class ZeroMQReceiver<T> extends Object implements akka.actor.Actor, ActorHelper, Logging
Constructor and Description |
---|
ZeroMQReceiver(String publisherUrl,
akka.zeromq.Subscribe subscribe,
scala.Function1<scala.collection.Seq<akka.util.ByteString>,scala.collection.Iterator<T>> bytesToObjects,
scala.reflect.ClassTag<T> evidence$1) |
Modifier and Type | Method and Description |
---|---|
void |
preStart() |
scala.PartialFunction<Object,scala.runtime.BoxedUnit> |
receive() |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, postStop, preRestart, self, sender, supervisorStrategy, unhandled
store, store, store
initializeIfNecessary, initializeLogging, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning