package com.sandu.ximon.admin.manager.iot.amqp;

import org.apache.qpid.jms.JmsConnectionListener;
import org.apache.qpid.jms.message.JmsInboundMessageDispatch;

import javax.jms.MessageConsumer;
import javax.jms.MessageProducer;
import javax.jms.Session;
import java.net.URI;

/**
 * @author chenjiantian
 * @date 2021/12/2 17:31
 */
public class AmqpConnectionListener implements JmsConnectionListener {
    @Override
    public void onConnectionEstablished(URI uri) {

    }

    @Override
    public void onConnectionFailure(Throwable throwable) {

    }

    @Override
    public void onConnectionInterrupted(URI uri) {

    }

    @Override
    public void onConnectionRestored(URI uri) {

    }

    @Override
    public void onInboundMessage(JmsInboundMessageDispatch jmsInboundMessageDispatch) {

    }

    @Override
    public void onSessionClosed(Session session, Throwable throwable) {

    }

    @Override
    public void onConsumerClosed(MessageConsumer messageConsumer, Throwable throwable) {

    }

    @Override
    public void onProducerClosed(MessageProducer messageProducer, Throwable throwable) {

    }
}