summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMartin Ritchie <ritchiem@apache.org>2008-08-21 09:34:41 +0000
committerMartin Ritchie <ritchiem@apache.org>2008-08-21 09:34:41 +0000
commit58579533900b04b23b9fda1e484994b076bf11a1 (patch)
treebd4c14902ffb58069ec73f1fa7c3a55f1c4c8ae2
parentb9903cbb7440f919d96de5ceffe5d13037e7a707 (diff)
downloadqpid-python-58579533900b04b23b9fda1e484994b076bf11a1.tar.gz
Remove old crufty helper that is not used.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@687667 13f79535-47bb-0310-9956-ffa450edef68
-rw-r--r--qpid/java/systests/src/main/java/org/apache/qpid/server/queue/MessageTestHelper.java102
1 files changed, 0 insertions, 102 deletions
diff --git a/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/MessageTestHelper.java b/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/MessageTestHelper.java
deleted file mode 100644
index b2a4216f8d..0000000000
--- a/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/MessageTestHelper.java
+++ /dev/null
@@ -1,102 +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.queue;
-
-import org.apache.qpid.framing.ContentHeaderBody;
-import org.apache.qpid.framing.AMQShortString;
-import org.apache.qpid.framing.abstraction.MessagePublishInfo;
-import org.apache.qpid.server.store.MessageStore;
-import org.apache.qpid.server.store.SkeletonMessageStore;
-import org.apache.qpid.server.store.StoreContext;
-import org.apache.qpid.server.registry.ApplicationRegistry;
-import org.apache.qpid.server.util.NullApplicationRegistry;
-import org.apache.qpid.server.txn.TransactionalContext;
-import org.apache.qpid.server.txn.NonTransactionalContext;
-import org.apache.qpid.server.RequiredDeliveryException;
-import org.apache.qpid.AMQException;
-
-import junit.framework.TestCase;
-
-import java.util.LinkedList;
-
-class MessageTestHelper extends TestCase
-{
- private final MessageStore _messageStore = new SkeletonMessageStore();
-
- private final StoreContext _storeContext = new StoreContext();
-
- private final TransactionalContext _txnContext = new NonTransactionalContext(_messageStore, _storeContext, null,
- new LinkedList<RequiredDeliveryException>()
- );
-
- MessageTestHelper() throws Exception
- {
- ApplicationRegistry.initialise(new NullApplicationRegistry());
- }
-
- QueueEntryImpl message() throws AMQException
- {
- return message(false);
- }
-
- QueueEntryImpl message(final boolean immediate) throws AMQException
- {
- MessagePublishInfo publish = new MessagePublishInfo()
- {
-
- public AMQShortString getExchange()
- {
- return null;
- }
-
- public void setExchange(AMQShortString exchange)
- {
- //To change body of implemented methods use File | Settings | File Templates.
- }
-
- public boolean isImmediate()
- {
- return immediate;
- }
-
- public boolean isMandatory()
- {
- return false;
- }
-
- public AMQShortString getRoutingKey()
- {
- return null;
- }
- };
-
- //public AMQMessage(Long messageId, AMQMessageHandle messageHandle , TransactionalContext txnConext, MessagePublishInfo info)
- long messageId = _messageStore.getNewMessageId();
- final AMQMessageHandle messageHandle =
- (new MessageHandleFactory()).createMessageHandle(messageId, _messageStore, false);
- messageHandle.setPublishAndContentHeaderBody(new StoreContext(),publish,new ContentHeaderBody());
- AMQMessage msg = new AMQMessage(messageHandle, _txnContext.getStoreContext(), publish);
-
-
- return new QueueEntryImpl(null,msg, Long.MIN_VALUE);
- }
-
-}