ome.smuggler.core.service.omero.impl

Class SessionKeepAliveHandler

java.lang.Object

ome.smuggler.core.service.omero.impl.SessionKeepAliveHandler

All Implemented Interfaces:

Reschedulable<QueuedOmeroKeepAlive>

public class SessionKeepAliveHandler
extends java.lang.Object
implements Reschedulable<QueuedOmeroKeepAlive>

Consumes a message from the session keep-alive queue by pinging the specified OMERO session. If the ping command succeeds, a new keep-alive is scheduled; otherwise the keep-alive cycle for the given session stops.

Constructor Summary

Constructors

Constructor and Description
SessionKeepAliveHandler(OmeroEnv env, SessionService service) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
java.util.Optional<Schedule<QueuedOmeroKeepAlive>>	consume(CountedSchedule current, QueuedOmeroKeepAlive data) Consumes the output of the channel this instance is bound to.

Methods inherited from class java.lang.Object

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

Constructor Detail

SessionKeepAliveHandler

public SessionKeepAliveHandler(OmeroEnv env,
                               SessionService service)

Creates a new instance.

Parameters:

env - the OMERO environment.

service - the session service.

Throws:

java.lang.NullPointerException - if any argument is null.

Method Detail

consume

public java.util.Optional<Schedule<QueuedOmeroKeepAlive>> consume(CountedSchedule current,
                                                                  QueuedOmeroKeepAlive data)

Description copied from interface: Reschedulable

Consumes the output of the channel this instance is bound to.

Specified by:

consume in interface Reschedulable<QueuedOmeroKeepAlive>

Parameters:

current - information about this invocation's schedule.

data - the data received from the channel.

Returns:

when and what data to input again in the channel or empty if no further action is required. Never return null.