|
ActiveMQ example source code file (ProxyConnection.java)
The ActiveMQ ProxyConnection.java source code/** * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package org.apache.activemq.proxy; import java.io.IOException; import java.util.concurrent.atomic.AtomicBoolean; import org.apache.activemq.Service; import org.apache.activemq.command.ShutdownInfo; import org.apache.activemq.command.WireFormatInfo; import org.apache.activemq.transport.DefaultTransportListener; import org.apache.activemq.transport.Transport; import org.apache.activemq.util.IOExceptionSupport; import org.apache.activemq.util.ServiceStopper; import org.slf4j.Logger; import org.slf4j.LoggerFactory; class ProxyConnection implements Service { private static final Logger LOG = LoggerFactory.getLogger(ProxyConnection.class); private final Transport localTransport; private final Transport remoteTransport; private AtomicBoolean shuttingDown = new AtomicBoolean(false); private AtomicBoolean running = new AtomicBoolean(false); public ProxyConnection(Transport localTransport, Transport remoteTransport) { this.localTransport = localTransport; this.remoteTransport = remoteTransport; } public void onFailure(IOException e) { if (!shuttingDown.get()) { LOG.debug("Transport error: " + e, e); try { stop(); } catch (Exception ignore) { } } } public void start() throws Exception { if (!running.compareAndSet(false, true)) { return; } this.localTransport.setTransportListener(new DefaultTransportListener() { public void onCommand(Object command) { boolean shutdown = false; if (command.getClass() == ShutdownInfo.class) { shuttingDown.set(true); shutdown = true; } // skipping WireFormat infos if (command.getClass() == WireFormatInfo.class) { return; } try { remoteTransport.oneway(command); if (shutdown) { stop(); } } catch (IOException error) { onFailure(error); } catch (Exception error) { onFailure(IOExceptionSupport.create(error)); } } public void onException(IOException error) { onFailure(error); } }); this.remoteTransport.setTransportListener(new DefaultTransportListener() { public void onCommand(Object command) { try { // skipping WireFormat infos if (command.getClass() == WireFormatInfo.class) { return; } localTransport.oneway(command); } catch (IOException error) { onFailure(error); } } public void onException(IOException error) { onFailure(error); } }); localTransport.start(); remoteTransport.start(); } public void stop() throws Exception { if (!running.compareAndSet(true, false)) { return; } shuttingDown.set(true); ServiceStopper ss = new ServiceStopper(); ss.stop(localTransport); ss.stop(remoteTransport); ss.throwFirstException(); } } Other ActiveMQ examples (source code examples)Here is a short list of links related to this ActiveMQ ProxyConnection.java source code file: |
... this post is sponsored by my books ... | |
#1 New Release! |
FP Best Seller |
Copyright 1998-2021 Alvin Alexander, alvinalexander.com
All Rights Reserved.
A percentage of advertising revenue from
pages under the /java/jwarehouse
URI on this website is
paid back to open source projects.