18#ifndef _ACTIVEMQ_TRANSPORT_FAILOVER_CLOSETRANSPORTSTASK_H_
19#define _ACTIVEMQ_TRANSPORT_FAILOVER_CLOSETRANSPORTSTASK_H_
32 using decaf::lang::Pointer;
#define AMQCPP_API
Definition Config.h:30
Represents a single task that can be part of a set of Tasks that are contained in a CompositeTaskRunn...
Definition CompositeTask.h:33
virtual bool iterate()
Return true until all transports have been closed and removed from the queue.
virtual ~CloseTransportsTask()
virtual bool isPending() const
This Task is pending if there are transports in the Queue that need to be closed.
void add(const Pointer< Transport > transport)
Add a new Transport to close.
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
A BlockingQueue derivative that allows for a bound to be placed on the number of elements that can be...
Definition LinkedBlockingQueue.h:52
Definition BackupTransport.h:31
Definition AbstractTransportFactory.h:30
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
Definition CachedConsumer.h:24