Package org.zeromq
Class ZActor.Double
- java.lang.Object
-
- org.zeromq.ZActor.Double
-
- All Implemented Interfaces:
ZPoller.EventsHandler
,ZStar.Star
- Enclosing class:
- ZActor
private static final class ZActor.Double extends java.lang.Object implements ZPoller.EventsHandler, ZStar.Star
-
-
Field Summary
Fields Modifier and Type Field Description private ZActor.Actor
actor
private ZContext
context
private ZMQ.Socket
pipe
private ZPoller
poller
private java.util.List<ZMQ.Socket>
sockets
-
Constructor Summary
Constructors Constructor Description Double(ZContext ctx, ZMQ.Socket pipe, ZActor.Actor actor, java.lang.Object... args)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
act(int events)
Where acting takes place ...
Hint: Can be used to process the events or input acquired from the previous step, or ...
Key point: in the middle of a loop.
Decision: to act on the next loop or notint
breathe()
Called when the star in on stage, just before acting.
Hint: Can be used to poll events or get input/events from other sources, or ...
Key point: a loop just started.boolean
entract()
Called as an interval between each act.
Hint: Can be used to perform decisions to continue next loop or not, or to send computed data to outputs, or ...
Key point: at the end of a loop.
Decision: to act on the next loop or notboolean
events(java.nio.channels.SelectableChannel channel, int events)
Called when the poller intercepts events.boolean
events(ZMQ.Socket socket, int events)
Called when the poller intercepts events.void
prepare()
Called when the star is in the wings.
Hint: Can be used to initialize the service, or ...
Key point: no loop has started already.boolean
renews()
Does the star want to renew for a new performance ? Hint: Can be used to perform decisions to continue looping or not, or to send computed data to outputs, or ...
Key point: the inner looping mechanism just ended
Decision: to exit or not
-
-
-
Field Detail
-
poller
private final ZPoller poller
-
pipe
private final ZMQ.Socket pipe
-
sockets
private final java.util.List<ZMQ.Socket> sockets
-
actor
private final ZActor.Actor actor
-
context
private final ZContext context
-
-
Constructor Detail
-
Double
public Double(ZContext ctx, ZMQ.Socket pipe, ZActor.Actor actor, java.lang.Object... args)
-
-
Method Detail
-
prepare
public void prepare()
Description copied from interface:ZStar.Star
Called when the star is in the wings.
Hint: Can be used to initialize the service, or ...
Key point: no loop has started already.- Specified by:
prepare
in interfaceZStar.Star
-
breathe
public int breathe()
Description copied from interface:ZStar.Star
Called when the star in on stage, just before acting.
Hint: Can be used to poll events or get input/events from other sources, or ...
Key point: a loop just started.- Specified by:
breathe
in interfaceZStar.Star
- Returns:
- the number of events to process
-
act
public boolean act(int events)
Description copied from interface:ZStar.Star
Where acting takes place ...
Hint: Can be used to process the events or input acquired from the previous step, or ...
Key point: in the middle of a loop.
Decision: to act on the next loop or not- Specified by:
act
in interfaceZStar.Star
- Parameters:
events
- the number of events to process- Returns:
- true to continue till the end of the act, false to stop loopS here.
-
entract
public boolean entract()
Description copied from interface:ZStar.Star
Called as an interval between each act.
Hint: Can be used to perform decisions to continue next loop or not, or to send computed data to outputs, or ...
Key point: at the end of a loop.
Decision: to act on the next loop or not- Specified by:
entract
in interfaceZStar.Star
- Returns:
- true to continue acting, false to stop loopS here.
-
renews
public boolean renews()
Description copied from interface:ZStar.Star
Does the star want to renew for a new performance ? Hint: Can be used to perform decisions to continue looping or not, or to send computed data to outputs, or ...
Key point: the inner looping mechanism just ended
Decision: to exit or not- Specified by:
renews
in interfaceZStar.Star
- Returns:
- true to restart acting, false to leave here
-
events
public boolean events(java.nio.channels.SelectableChannel channel, int events)
Description copied from interface:ZPoller.EventsHandler
Called when the poller intercepts events.- Specified by:
events
in interfaceZPoller.EventsHandler
- Parameters:
channel
- the channel with eventsevents
- the interesting events as an ORed combination of IN, OUT, ERR- Returns:
- true to continue the polling, false to stop it
-
events
public boolean events(ZMQ.Socket socket, int events)
Description copied from interface:ZPoller.EventsHandler
Called when the poller intercepts events.- Specified by:
events
in interfaceZPoller.EventsHandler
- Parameters:
socket
- the socket with eventsevents
- the interesting events as an ORed combination of IN, OUT, ERR- Returns:
- true to continue the polling, false to stop it
-
-