AmqpChannelWrapper

Open source code

Methods Summary
`public`	# `__construct( PhpAmqpLib\Channel\AMQPChannel $channel )`
`public`	# `registerConsumer( SAREhub\Client\Amqp\AmqpConsumer $consumer )`
`public`	# `unregisterConsumer( string $consumerTag )`
`public`	# `onMessage( PhpAmqpLib\Message\AMQPMessage $in )`
`protected`	# `doTick( )` Overrides `SAREhub\Commons\Service\ServiceSupport::doTick()`
`public`	# `ack( SAREhub\Client\Message\Message $message )`
`public`	# `reject( SAREhub\Client\Message\Message $message , bool $requeue = true )`
`public`	# `publish( SAREhub\Client\Message\Message $message )`
`public`	# `setChannelPrefetchCount( int $count , int $size = 0 )`
`public`	# `setPrefetchCountPerConsumer( int $count , int $size = 0 )`
`public`	# `getWaitTimeout( )`
`public`	# `setWaitTimeout( int $timeout )`
`public`	# `getConsumer( string $consumerTag )`
`public`	# `hasConsumer( string $consumerTag )`
`public`	# `getConsumers( )`
`public`	# `getWrappedChannel( )`
`public`	# `getMessageConverter( )`
`public`	# `setMessageConverter( SAREhub\Client\Amqp\AmqpMessageConverter $messageConverter )`
`public`	# `getProcessConfirmStrategy( )`
`public`	# `setProcessConfirmStrategy( SAREhub\Client\Amqp\AmqpProcessConfirmStrategy $processConfirmStrategy )`

Methods inherited from SAREhub\Commons\Service\ServiceSupport
`start()`, `tick()`, `stop()`, `isStarted()`, `isStopped()`, `isRunning()`, `getLogger()`, `setLogger()`, `doStart()`, `doTick()`, `doStop()`

Constants Summary
`public int`	`DEFAULT_WAIT_TIMEOUT`	# `1`

Overrides