io.micronaut.rabbitmq.connect

Class ChannelInitializer

java.lang.Object

io.micronaut.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
void	initialize(com.rabbitmq.client.Channel channel) Deprecated. Override initialize(Channel, String) instead
void	initialize(com.rabbitmq.client.Channel channel, java.lang.String name) 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

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

Deprecated. Override initialize(Channel, String) instead

Do any work with a channel.

Parameters:

channel - The channel to use

Throws:

java.io.IOException - If any error occurs

initialize

public void initialize(com.rabbitmq.client.Channel channel,
                       java.lang.String name)
                throws java.io.IOException

Do any work with a channel.

Parameters:

channel - The channel to use

name - The name of the channel pool, like configured under `rabbitmq.servers`

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>