1 files changed, 0 insertions, 176 deletions
diff --git a/java/common/src/main/java/org/apache/qpid/transport/Channel.java b/java/common/src/main/java/org/apache/qpid/transport/Channel.java
deleted file mode 100644
index d6b015930b..0000000000
--- a/java/common/src/main/java/org/apache/qpid/transport/Channel.java
+++ /dev/null
@@ -1,176 +0,0 @@
-/*
- *
- * 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.qpid.transport;
-
-import org.apache.qpid.transport.network.Frame;
-import org.apache.qpid.transport.util.Logger;
-
-import java.nio.ByteBuffer;
-
-import java.util.ArrayList;
-import java.util.List;
-import java.util.concurrent.locks.Lock;
-import java.util.concurrent.locks.ReentrantLock;
-
-import static org.apache.qpid.transport.network.Frame.*;
-import static org.apache.qpid.transport.util.Functions.*;
-
-
-/**
- * Channel
- *
- * @author Rafael H. Schloming
- */
-
-public class Channel extends Invoker
-    implements Receiver<ProtocolEvent>, ProtocolDelegate<Void>
-{
-
-    private static final Logger log = Logger.get(Channel.class);
-
-    final private Connection connection;
-    final private int channel;
-    final private MethodDelegate<Channel> delegate;
-    final private SessionDelegate sessionDelegate;
-    // session may be null
-    private Session session;
-
-    public Channel(Connection connection, int channel, SessionDelegate delegate)
-    {
-        this.connection = connection;
-        this.channel = channel;
-        this.delegate = new ChannelDelegate();
-        this.sessionDelegate = delegate;
-    }
-
-    public Connection getConnection()
-    {
-        return connection;
-    }
-
-    public void received(ProtocolEvent event)
-    {
-        event.delegate(null, this);
-    }
-
-    public void init(Void v, ProtocolHeader hdr)
-    {
-        connection.getConnectionDelegate().init(this, hdr);
-    }
-
-    public void control(Void v, Method method)
-    {
-        switch (method.getEncodedTrack())
-        {
-        case L1:
-            method.dispatch(this, connection.getConnectionDelegate());
-            break;
-        case L2:
-            method.dispatch(this, delegate);
-            break;
-        case L3:
-            method.delegate(session, sessionDelegate);
-            break;
-        default:
-            throw new IllegalStateException
-                ("unknown track: " + method.getEncodedTrack());
-        }
-    }
-
-    public void command(Void v, Method method)
-    {
-        method.delegate(session, sessionDelegate);
-    }
-
-    public void error(Void v, ProtocolError error)
-    {
-        throw new RuntimeException(error.getMessage());
-    }
-
-    public void exception(Throwable t)
-    {
-        session.exception(t);
-    }
-
-    public void closed()
-    {
-        log.debug("channel closed: ", this);
-        if (session != null)
-        {
-            session.closed();
-        }
-        connection.removeChannel(channel);
-    }
-
-    public int getEncodedChannel() {
-        return channel;
-    }
-
-    public Session getSession()
-    {
-        return session;
-    }
-
-    void setSession(Session session)
-    {
-        this.session = session;
-    }
-
-    void closeCode(ConnectionClose close)
-    {
-        if (session != null)
-        {
-            session.closeCode(close);
-        }
-    }
-
-    private void emit(ProtocolEvent event)
-    {
-        event.setChannel(channel);
-        connection.send(event);
-    }
-
-    public void method(Method m)
-    {
-        emit(m);
-
-        if (!m.isBatch())
-        {
-            connection.flush();
-        }
-    }
-
-    protected void invoke(Method m)
-    {
-        method(m);
-    }
-
-    protected <T> Future<T> invoke(Method m, Class<T> cls)
-    {
-        throw new UnsupportedOperationException();
-    }
-
-    public String toString()
-    {
-        return String.format("%s:%s", connection, channel);
-    }
-
-}