18#ifndef _ACTIVEMQ_TRANSPORT_INACTIVITY_INACTIVITYMONITOR_H_
19#define _ACTIVEMQ_TRANSPORT_INACTIVITY_INACTIVITYMONITOR_H_
38 class AsyncSignalReadErrorkTask;
40 class InactivityMonitorData;
42 class AMQCPP_API InactivityMonitor :
public TransportFilter {
46 InactivityMonitorData* members;
55 InactivityMonitor(
const InactivityMonitor&);
56 InactivityMonitor operator=(
const InactivityMonitor&);
106 bool allowReadCheck(
long long elapsed);
115 void stopMonitorThreads();
118 void startMonitorThreads();
#define AMQCPP_API
Definition Config.h:30
Pointer< Transport > next
The transport that this filter wraps around.
Definition TransportFilter.h:54
bool isKeepAliveResponseRequired() const
friend class AsyncWriteTask
Definition InactivityMonitor.h:51
void setReadCheckTime(long long value)
friend class WriteChecker
Definition InactivityMonitor.h:50
long long getInitialDelayTime() const
void setInitialDelayTime(long long value) const
friend class AsyncSignalReadErrorkTask
Definition InactivityMonitor.h:49
void setWriteCheckTime(long long value)
virtual void onException(const decaf::lang::Exception &ex)
Event handler for an exception from a command transport.
long long getReadCheckTime() const
virtual void onCommand(const Pointer< Command > command)
Event handler for the receipt of a command.
virtual ~InactivityMonitor()
friend class ReadChecker
Definition InactivityMonitor.h:48
virtual void beforeNextIsStopped()
Subclasses can override this method to do their own pre-stop work.
InactivityMonitor(const Pointer< Transport > next, const Pointer< wireformat::WireFormat > wireFormat)
virtual void afterNextIsStarted()
Subclasses can override this method to do their own post startup work.
virtual void doClose()
Subclasses can override this method to do their own close work.
void setKeepAliveResponseRequired(bool value)
long long getWriteCheckTime() const
InactivityMonitor(const Pointer< Transport > next, const decaf::util::Properties &properties, const Pointer< wireformat::WireFormat > wireFormat)
virtual void oneway(const Pointer< Command > command)
Sends a one-way command.
Runnable class that is used by the {.
Definition ReadChecker.h:37
Runnable class used by the {.
Definition WriteChecker.h:38
Definition Exception.h:38
Decaf's implementation of a Smart Pointer that is a template on a Type and is Thread Safe if the defa...
Definition Pointer.h:53
Java-like properties class for mapping string names to string values.
Definition Properties.h:53
Definition InactivityMonitor.h:32
Definition AbstractTransportFactory.h:30
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
Definition CachedConsumer.h:24