[jboss-cvs] JBossAS SVN: r105345 - projects/cluster/ha-server-core/trunk/src/main/java/org/jboss/ha/core/framework/server.
jboss-cvs-commits at lists.jboss.org
jboss-cvs-commits at lists.jboss.org
Fri May 28 18:58:38 EDT 2010
Author: bstansberry at jboss.com
Date: 2010-05-28 18:58:38 -0400 (Fri, 28 May 2010)
New Revision: 105345
Removed:
projects/cluster/ha-server-core/trunk/src/main/java/org/jboss/ha/core/framework/server/MuxHandlerChannel.java
Log:
Remove MuxHandlerChannel; not part of this project
Deleted: projects/cluster/ha-server-core/trunk/src/main/java/org/jboss/ha/core/framework/server/MuxHandlerChannel.java
===================================================================
--- projects/cluster/ha-server-core/trunk/src/main/java/org/jboss/ha/core/framework/server/MuxHandlerChannel.java 2010-05-28 22:36:13 UTC (rev 105344)
+++ projects/cluster/ha-server-core/trunk/src/main/java/org/jboss/ha/core/framework/server/MuxHandlerChannel.java 2010-05-28 22:58:38 UTC (rev 105345)
@@ -1,418 +0,0 @@
-/*
- * JBoss, Home of Professional Open Source.
- * Copyright 2010, Red Hat, Inc. and individual contributors
- * as indicated by the @author tags. See the copyright.txt file in the
- * distribution for a full listing of individual contributors.
- *
- * This is free software; you can redistribute it and/or modify it
- * under the terms of the GNU Lesser General Public License as
- * published by the Free Software Foundation; either version 2.1 of
- * the License, or (at your option) any later version.
- *
- * This software is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
- * Lesser General Public License for more details.
- *
- * You should have received a copy of the GNU Lesser General Public
- * License along with this software; if not, write to the Free
- * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
- * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
- */
-
-package org.jboss.ha.core.framework.server;
-
-import java.io.Serializable;
-import java.util.List;
-import java.util.Map;
-import java.util.Vector;
-
-import org.jgroups.Address;
-import org.jgroups.Channel;
-import org.jgroups.ChannelClosedException;
-import org.jgroups.ChannelException;
-import org.jgroups.ChannelListener;
-import org.jgroups.ChannelNotConnectedException;
-import org.jgroups.Event;
-import org.jgroups.Message;
-import org.jgroups.Receiver;
-import org.jgroups.TimeoutException;
-import org.jgroups.UpHandler;
-import org.jgroups.View;
-import org.jgroups.logging.Log;
-import org.jgroups.logging.LogFactory;
-import org.jgroups.stack.ProtocolStack;
-
-/**
- *
- *
- * @author Brian Stansberry
- *
- * @version $Revision$
- */
-public class MuxHandlerChannel extends Channel
-{
- private final Log log=LogFactory.getLog(MuxHandlerChannel.class);
- private final Channel delegate;
- private MuxUpHandler upHandler;
-
- public MuxHandlerChannel(Channel delegate)
- {
- this.delegate = delegate;
- UpHandler uh = delegate.getUpHandler();
- if (uh == null)
- {
- this.upHandler = new MuxUpHandler();
- this.delegate.setUpHandler(upHandler);
- }
- else if (uh instanceof MuxUpHandler)
- {
- this.upHandler = (MuxUpHandler) uh;
- }
- else
- {
- throw new IllegalStateException("delegate Channel already has a non-Mux UpHandler");
- }
- }
-
- @Override
- public void blockOk()
- {
- delegate.blockOk();
- }
-
- @Override
- public void close()
- {
- delegate.close();
- }
-
- @Override
- public void connect(String clusterName) throws ChannelException
- {
- delegate.connect(clusterName);
- }
-
- @Override
- public void connect(String clusterName, Address target, String stateId, long timeout) throws ChannelException
- {
- delegate.connect(clusterName, target, stateId, timeout);
- }
-
- @Override
- public void disconnect()
- {
- delegate.disconnect();
- }
-
- @Override
- public Map<String, Object> dumpStats()
- {
- return delegate.dumpStats();
- }
-
- @Override
- public boolean flushSupported()
- {
- return delegate.flushSupported();
- }
-
- @Override
- public Address getAddress()
- {
- return delegate.getAddress();
- }
-
- @Override
- public boolean getAllStates(Vector targets, long timeout) throws ChannelNotConnectedException,
- ChannelClosedException
- {
- return delegate.getAllStates(targets, timeout);
- }
-
- @Override
- public String getChannelName()
- {
- return delegate.getChannelName();
- }
-
- @Override
- public String getClusterName()
- {
- return delegate.getClusterName();
- }
-
- @Override
- public Map<String, Object> getInfo()
- {
- return delegate.getInfo();
- }
-
- @Override
- public Address getLocalAddress()
- {
- return delegate.getLocalAddress();
- }
-
- @Override
- protected Log getLog()
- {
- return log;
- }
-
- @Override
- public String getName()
- {
- return delegate.getName();
- }
-
- @Override
- public String getName(Address member)
- {
- return delegate.getName(member);
- }
-
- @Override
- public Object getOpt(int option)
- {
- return delegate.getOpt(option);
- }
-
- @Override
- public ProtocolStack getProtocolStack()
- {
- return delegate.getProtocolStack();
- }
-
- @Override
- public boolean getState(Address target, long timeout) throws ChannelNotConnectedException, ChannelClosedException
- {
- return delegate.getState(target, timeout);
- }
-
- @Override
- public boolean getState(Address target, String stateId, long timeout) throws ChannelNotConnectedException,
- ChannelClosedException
- {
- return delegate.getState(target, stateId, timeout);
- }
-
- @Override
- public View getView()
- {
- return delegate.getView();
- }
-
- @Override
- public boolean isConnected()
- {
- return delegate.isConnected();
- }
-
- @Override
- public boolean isOpen()
- {
- return delegate.isOpen();
- }
-
- @Override
- public Object peek(long timeout) throws ChannelNotConnectedException, ChannelClosedException, TimeoutException
- {
- return delegate.peek(timeout);
- }
-
- @Override
- public Object receive(long timeout) throws ChannelNotConnectedException, ChannelClosedException, TimeoutException
- {
- return delegate.receive(timeout);
- }
-
- @Override
- public void returnState(byte[] state)
- {
- delegate.returnState(state);
- }
-
- @Override
- public void returnState(byte[] state, String stateId)
- {
- delegate.returnState(state, stateId);
- }
-
- @Override
- public void send(Message msg) throws ChannelNotConnectedException, ChannelClosedException
- {
- delegate.send(msg);
- }
-
- @Override
- public void send(Address dst, Address src, Serializable obj) throws ChannelNotConnectedException,
- ChannelClosedException
- {
- delegate.send(dst, src, obj);
- }
-
- @Override
- public void send(Address dst, Address src, byte[] buf) throws ChannelNotConnectedException, ChannelClosedException
- {
- delegate.send(dst, src, buf);
- }
-
- @Override
- public void send(Address dst, Address src, byte[] buf, int offset, int length) throws ChannelNotConnectedException,
- ChannelClosedException
- {
- delegate.send(dst, src, buf, offset, length);
- }
-
- @Override
- public void setInfo(String key, Object value)
- {
- delegate.setInfo(key, value);
- }
-
- @Override
- public void setName(String name)
- {
- delegate.setName(name);
- }
-
- @Override
- public void setOpt(int option, Object value)
- {
- delegate.setOpt(option, value);
- }
-
- @Override
- public void shutdown()
- {
- delegate.shutdown();
- }
-
- @Override
- public boolean startFlush(boolean automaticResume)
- {
- return delegate.startFlush(automaticResume);
- }
-
- @Override
- public boolean startFlush(List<Address> flushParticipants, boolean automaticResume)
- {
- return delegate.startFlush(flushParticipants, automaticResume);
- }
-
- @Override
- public boolean startFlush(long timeout, boolean automaticResume)
- {
- return delegate.startFlush(timeout, automaticResume);
- }
-
- @Override
- public void stopFlush()
- {
- delegate.stopFlush();
- }
-
- @Override
- public void stopFlush(List<Address> flushParticipants)
- {
- delegate.stopFlush(flushParticipants);
- }
-
- @Override
- public synchronized void addChannelListener(ChannelListener listener)
- {
- delegate.addChannelListener(listener);
- }
-
- @Override
- public synchronized void clearChannelListeners()
- {
- delegate.clearChannelListeners();
- }
-
- @Override
- public void down(Event evt)
- {
- delegate.down(evt);
- }
-
- @Override
- public Object downcall(Event evt)
- {
- return delegate.downcall(evt);
- }
-
- @Override
- public String dumpQueue()
- {
- return delegate.dumpQueue();
- }
-
- @Override
- public int getNumMessages()
- {
- return delegate.getNumMessages();
- }
-
- @Override
- public String getProperties()
- {
- return delegate.getProperties();
- }
-
- @Override
- public Receiver getReceiver()
- {
- return delegate.getReceiver();
- }
-
- @Override
- public UpHandler getUpHandler()
- {
- // We hide the upHandler from callers so they will set it. Yuck!
- return null;
- }
-
- @Override
- public void open() throws ChannelException
- {
- delegate.open();
- }
-
- @Override
- public synchronized void removeChannelListener(ChannelListener listener)
- {
- delegate.removeChannelListener(listener);
- }
-
- @Override
- public void setChannelListener(ChannelListener channelListener)
- {
- delegate.setChannelListener(channelListener);
- }
-
- @Override
- public void setReceiver(Receiver r)
- {
- delegate.setReceiver(r);
- }
-
- @Override
- public void setUpHandler(UpHandler upHandler)
- {
- if (this.upHandler != null)
- {
- throw new IllegalStateException("UpHandler already set");
- }
- this.upHandler = new MuxUpHandler(upHandler);
- delegate.setUpHandler(this.upHandler);
- }
-
- public MuxUpHandler getMuxUpHandler()
- {
- return upHandler;
- }
-
-
-}
More information about the jboss-cvs-commits
mailing list