1 files changed, 0 insertions, 109 deletions
diff --git a/java/broker/src/main/java/org/apache/qpid/server/subscription/Subscription.java b/java/broker/src/main/java/org/apache/qpid/server/subscription/Subscription.java
deleted file mode 100644
index 0a3576ff42..0000000000
--- a/java/broker/src/main/java/org/apache/qpid/server/subscription/Subscription.java
+++ /dev/null
@@ -1,109 +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.server.subscription;
-
-import org.apache.qpid.AMQException;
-import org.apache.qpid.framing.AMQShortString;
-import org.apache.qpid.server.AMQChannel;
-import org.apache.qpid.server.logging.LogActor;
-import org.apache.qpid.server.queue.AMQQueue;
-import org.apache.qpid.server.queue.QueueEntry;
-
-public interface Subscription
-{
-    LogActor getLogActor();
-
-    boolean isTransient();
-
-    public static enum State
-    {
-        ACTIVE,
-        SUSPENDED,
-        CLOSED
-    }
-
-    public static interface StateListener
-    {
-        public void stateChange(Subscription sub, State oldState, State newState);
-    }
-
-    AMQQueue getQueue();
-
-    QueueEntry.SubscriptionAcquiredState getOwningState();
-    QueueEntry.SubscriptionAssignedState getAssignedState();
-
-
-    void setQueue(AMQQueue queue, boolean exclusive);
-
-    void setNoLocal(boolean noLocal);
-
-    AMQShortString getConsumerTag();
-
-    long getSubscriptionID();
-
-    boolean isSuspended();
-
-    boolean hasInterest(QueueEntry msg);
-
-    boolean isAutoClose();
-
-    boolean isClosed();
-
-    boolean acquires();
-
-    boolean seesRequeues();
-
-    void close();
-
-    void send(QueueEntry msg) throws AMQException;
-
-    void queueDeleted(AMQQueue queue);
-
-
-    boolean wouldSuspend(QueueEntry msg);
-
-    void getSendLock();
-
-    void releaseSendLock();
-
-    void onDequeue(final QueueEntry queueEntry);
-
-    void restoreCredit(final QueueEntry queueEntry);
-
-    void setStateListener(final StateListener listener);
-
-    public State getState();
-
-    AMQQueue.Context getQueueContext();
-
-    void setQueueContext(AMQQueue.Context queueContext);
-
-
-    boolean isActive();
-
-    void confirmAutoClose();
-
-    public void set(String key, Object value);
-
-    public Object get(String key);
-
-    boolean isSessionTransactional();
-}