io.micronaut.configuration.rabbitmq.connect

Class ChannelInitializer

java.lang.Object

io.micronaut.configuration.rabbitmq.connect.ChannelInitializer

All Implemented Interfaces:

io.micronaut.context.event.BeanCreatedEventListener<ChannelPool>, java.util.EventListener

public abstract class ChannelInitializer
extends java.lang.Object
implements io.micronaut.context.event.BeanCreatedEventListener<ChannelPool>

A base class to extend from to do initialization work with a channel before any consumers or producers are created.

Since:

1.1.0

Author:

James Kleeh

Constructor Summary

Constructors

Constructor and Description
ChannelInitializer()

Method Summary

Modifier and Type	Method and Description
abstract void	initialize(com.rabbitmq.client.Channel channel) Do any work with a channel.
ChannelPool	onCreated(io.micronaut.context.event.BeanCreatedEvent<ChannelPool> event)

Methods inherited from class java.lang.Object

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

Constructor Detail

ChannelInitializer

public ChannelInitializer()

Method Detail

initialize

public abstract void initialize(com.rabbitmq.client.Channel channel)
                         throws java.io.IOException

Do any work with a channel.

Parameters:

channel - The channel to use

Throws:

java.io.IOException - If any error occurs

onCreated

public ChannelPool onCreated(io.micronaut.context.event.BeanCreatedEvent<ChannelPool> event)

Specified by:

onCreated in interface io.micronaut.context.event.BeanCreatedEventListener<ChannelPool>