[hornetq-commits] JBoss hornetq SVN: r8105 - in branches/hornetq_grouping: tests/src/org/hornetq/tests/integration/cluster/distribution and 1 other directories.

Author: ataylor Date: 2009-10-14 06:13:49 -0400 (Wed, 14 Oct 2009) New Revision: 8105 Removed: branches/hornetq_grouping/tests/src/org/hornetq/tests/unit/core/postoffice/impl/BindingImplTest.java Modified: branches/hornetq_grouping/src/main/org/hornetq/core/postoffice/impl/BindingsImpl.java branches/hornetq_grouping/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java branches/hornetq_grouping/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusteredGroupingTest.java Log: fixes Modified: branches/hornetq_grouping/src/main/org/hornetq/core/postoffice/impl/BindingsImpl.java =================================================================== --- branches/hornetq_grouping/src/main/org/hornetq/core/postoffice/impl/BindingsImpl.java 2009-10-14 10:00:17 UTC (rev 8104) +++ branches/hornetq_grouping/src/main/org/hornetq/core/postoffice/impl/BindingsImpl.java 2009-10-14 10:13:49 UTC (rev 8105) @@ -438,29 +438,33 @@ throws Exception { SimpleString groupId = (SimpleString) message.getProperty(MessageImpl.HDR_GROUP_ID); - Response resp = groupingGroupingHandler.propose(new Proposal(groupId, null)); - if (resp == null) + + for (Map.Entry<SimpleString, List<Binding>> entry : routingNameBindingMap.entrySet()) { - for (Map.Entry<SimpleString, List<Binding>> entry : routingNameBindingMap.entrySet()) + SimpleString routingName = entry.getKey(); + + List<Binding> bindings = entry.getValue(); + + if (bindings == null) { - SimpleString routingName = entry.getKey(); + // The value can become null if it's concurrently removed while we're iterating - this is expected + // ConcurrentHashMap behaviour! + continue; + } - List<Binding> bindings = entry.getValue(); + SimpleString fullID = groupId.concat(".").concat(routingName); - if (bindings == null) - { - // The value can become null if it's concurrently removed while we're iterating - this is expected - // ConcurrentHashMap behaviour! - continue; - } + Response resp = groupingGroupingHandler.propose(new Proposal(fullID, null)); + if (resp == null) + { + Binding chosen = getNextBinding(message, routingName, bindings); - Binding chosen = getNextBinding(message, routingName, bindings); - - resp = groupingGroupingHandler.propose(new Proposal(groupId, chosen.getClusterName())); - + resp = groupingGroupingHandler.propose(new Proposal(fullID, chosen.getClusterName())); + if (!resp.getChosen().equals(chosen.getClusterName())) { + chosen = null; for (Binding binding : bindings) { if (binding.getClusterName().equals(resp.getChosen())) @@ -477,15 +481,13 @@ chosen.getBindable().preroute(message, tx); chosen.getBindable().route(message, tx); } + else + { + throw new HornetQException(HornetQException.QUEUE_DOES_NOT_EXIST, "queue " + resp.getChosen() + " has been removed cannot deliver message, queues should not be removed when grouping is used"); + } } - } - else - { - for (Map.Entry<SimpleString, List<Binding>> entry : routingNameBindingMap.entrySet()) + else { - SimpleString routingName = entry.getKey(); - - List<Binding> bindings = entry.getValue(); Binding chosen = null; for (Binding binding : bindings) { @@ -506,7 +508,11 @@ throw new HornetQException(HornetQException.QUEUE_DOES_NOT_EXIST, "queue " + resp.getChosen() + " has been removed cannot deliver message, queues should not be removed when grouping is used"); } } + + } + + } private final int incrementPos(int pos, int length) Modified: branches/hornetq_grouping/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java =================================================================== --- branches/hornetq_grouping/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java 2009-10-14 10:00:17 UTC (rev 8104) +++ branches/hornetq_grouping/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java 2009-10-14 10:13:49 UTC (rev 8105) @@ -453,7 +453,7 @@ } - protected void setUpGroupArbitrator(GroupingHandlerConfiguration.TYPE type, int node) + protected void setUpGroupHandler(GroupingHandlerConfiguration.TYPE type, int node) { GroupingHandler groupingHandler; if(type == GroupingHandlerConfiguration.TYPE.LOCAL) Modified: branches/hornetq_grouping/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusteredGroupingTest.java =================================================================== --- branches/hornetq_grouping/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusteredGroupingTest.java 2009-10-14 10:00:17 UTC (rev 8104) +++ branches/hornetq_grouping/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusteredGroupingTest.java 2009-10-14 10:13:49 UTC (rev 8105) @@ -39,9 +39,9 @@ try { - setUpGroupArbitrator(GroupingHandlerConfiguration.TYPE.LOCAL, 0); - setUpGroupArbitrator(GroupingHandlerConfiguration.TYPE.REMOTE, 1); - setUpGroupArbitrator(GroupingHandlerConfiguration.TYPE.REMOTE, 2); + setUpGroupHandler(GroupingHandlerConfiguration.TYPE.LOCAL, 0); + setUpGroupHandler(GroupingHandlerConfiguration.TYPE.REMOTE, 1); + setUpGroupHandler(GroupingHandlerConfiguration.TYPE.REMOTE, 2); setupSessionFactory(0, isNetty()); setupSessionFactory(1, isNetty()); @@ -95,9 +95,9 @@ try { - setUpGroupArbitrator(GroupingHandlerConfiguration.TYPE.LOCAL, 0); - setUpGroupArbitrator(GroupingHandlerConfiguration.TYPE.REMOTE, 1); - setUpGroupArbitrator(GroupingHandlerConfiguration.TYPE.REMOTE, 2); + setUpGroupHandler(GroupingHandlerConfiguration.TYPE.LOCAL, 0); + setUpGroupHandler(GroupingHandlerConfiguration.TYPE.REMOTE, 1); + setUpGroupHandler(GroupingHandlerConfiguration.TYPE.REMOTE, 2); setupSessionFactory(0, isNetty()); setupSessionFactory(1, isNetty()); @@ -154,9 +154,9 @@ try { - setUpGroupArbitrator(GroupingHandlerConfiguration.TYPE.LOCAL, 0); - setUpGroupArbitrator(GroupingHandlerConfiguration.TYPE.REMOTE, 1); - setUpGroupArbitrator(GroupingHandlerConfiguration.TYPE.REMOTE, 2); + setUpGroupHandler(GroupingHandlerConfiguration.TYPE.LOCAL, 0); + setUpGroupHandler(GroupingHandlerConfiguration.TYPE.REMOTE, 1); + setUpGroupHandler(GroupingHandlerConfiguration.TYPE.REMOTE, 2); setupSessionFactory(0, isNetty()); setupSessionFactory(1, isNetty()); @@ -216,9 +216,9 @@ try { - setUpGroupArbitrator(GroupingHandlerConfiguration.TYPE.LOCAL, 0); - setUpGroupArbitrator(GroupingHandlerConfiguration.TYPE.REMOTE, 1); - setUpGroupArbitrator(GroupingHandlerConfiguration.TYPE.REMOTE, 2); + setUpGroupHandler(GroupingHandlerConfiguration.TYPE.LOCAL, 0); + setUpGroupHandler(GroupingHandlerConfiguration.TYPE.REMOTE, 1); + setUpGroupHandler(GroupingHandlerConfiguration.TYPE.REMOTE, 2); setupSessionFactory(0, isNetty()); setupSessionFactory(1, isNetty()); @@ -276,9 +276,9 @@ try { - setUpGroupArbitrator(GroupingHandlerConfiguration.TYPE.LOCAL, 0); - setUpGroupArbitrator(GroupingHandlerConfiguration.TYPE.REMOTE, 1); - setUpGroupArbitrator(GroupingHandlerConfiguration.TYPE.REMOTE, 2); + setUpGroupHandler(GroupingHandlerConfiguration.TYPE.LOCAL, 0); + setUpGroupHandler(GroupingHandlerConfiguration.TYPE.REMOTE, 1); + setUpGroupHandler(GroupingHandlerConfiguration.TYPE.REMOTE, 2); setupSessionFactory(0, isNetty()); setupSessionFactory(1, isNetty()); @@ -340,9 +340,9 @@ try { - setUpGroupArbitrator(GroupingHandlerConfiguration.TYPE.LOCAL, 0); - setUpGroupArbitrator(GroupingHandlerConfiguration.TYPE.REMOTE, 1); - setUpGroupArbitrator(GroupingHandlerConfiguration.TYPE.REMOTE, 2); + setUpGroupHandler(GroupingHandlerConfiguration.TYPE.LOCAL, 0); + setUpGroupHandler(GroupingHandlerConfiguration.TYPE.REMOTE, 1); + setUpGroupHandler(GroupingHandlerConfiguration.TYPE.REMOTE, 2); setupSessionFactory(0, isNetty()); setupSessionFactory(1, isNetty()); @@ -360,7 +360,11 @@ waitForBindings(1, "queues.testaddress", 1, 1, true); waitForBindings(2, "queues.testaddress", 1, 1, true); + waitForBindings(0, "queues.testaddress", 2, 2, false); + waitForBindings(1, "queues.testaddress", 2, 2, false); + waitForBindings(2, "queues.testaddress", 2, 2, false); + sendInRange(0, "queues.testaddress", 0, 10, false, MessageImpl.HDR_GROUP_ID, new SimpleString("id1")); sendInRange(0, "queues.testaddress", 10, 20, false, MessageImpl.HDR_GROUP_ID, new SimpleString("id2")); sendInRange(0, "queues.testaddress", 20, 30, false, MessageImpl.HDR_GROUP_ID, new SimpleString("id3")); @@ -396,9 +400,9 @@ try { - setUpGroupArbitrator(GroupingHandlerConfiguration.TYPE.LOCAL, 0); - setUpGroupArbitrator(GroupingHandlerConfiguration.TYPE.REMOTE, 1); - setUpGroupArbitrator(GroupingHandlerConfiguration.TYPE.REMOTE, 2); + setUpGroupHandler(GroupingHandlerConfiguration.TYPE.LOCAL, 0); + setUpGroupHandler(GroupingHandlerConfiguration.TYPE.REMOTE, 1); + setUpGroupHandler(GroupingHandlerConfiguration.TYPE.REMOTE, 2); setupSessionFactory(0, isNetty()); setupSessionFactory(1, isNetty()); @@ -486,9 +490,9 @@ try { - setUpGroupArbitrator(GroupingHandlerConfiguration.TYPE.LOCAL, 0); - setUpGroupArbitrator(GroupingHandlerConfiguration.TYPE.REMOTE, 1); - setUpGroupArbitrator(GroupingHandlerConfiguration.TYPE.REMOTE, 2); + setUpGroupHandler(GroupingHandlerConfiguration.TYPE.LOCAL, 0); + setUpGroupHandler(GroupingHandlerConfiguration.TYPE.REMOTE, 1); + setUpGroupHandler(GroupingHandlerConfiguration.TYPE.REMOTE, 2); setupSessionFactory(0, isNetty()); setupSessionFactory(1, isNetty()); @@ -516,9 +520,6 @@ sendInRange(2, "queues.testaddress", 10, 20, false, MessageImpl.HDR_GROUP_ID, new SimpleString("id1")); - - sendInRange(0, "queues.testaddress", 20, 30, false, MessageImpl.HDR_GROUP_ID, new SimpleString("id1")); - startServers(1); addConsumer(1, 1, "queue0", null); @@ -526,7 +527,6 @@ verifyReceiveAllInRange(10, 20, 1); - verifyReceiveAllInRange(20, 30, 1); System.out.println("*****************************************************************************"); } @@ -556,9 +556,9 @@ try { - setUpGroupArbitrator(GroupingHandlerConfiguration.TYPE.LOCAL, 0); - setUpGroupArbitrator(GroupingHandlerConfiguration.TYPE.REMOTE, 1); - setUpGroupArbitrator(GroupingHandlerConfiguration.TYPE.REMOTE, 2); + setUpGroupHandler(GroupingHandlerConfiguration.TYPE.LOCAL, 0); + setUpGroupHandler(GroupingHandlerConfiguration.TYPE.REMOTE, 1); + setUpGroupHandler(GroupingHandlerConfiguration.TYPE.REMOTE, 2); setupSessionFactory(0, isNetty()); setupSessionFactory(1, isNetty()); @@ -630,9 +630,9 @@ try { - setUpGroupArbitrator(GroupingHandlerConfiguration.TYPE.LOCAL, 0); - setUpGroupArbitrator(GroupingHandlerConfiguration.TYPE.REMOTE, 1); - setUpGroupArbitrator(GroupingHandlerConfiguration.TYPE.REMOTE, 2); + setUpGroupHandler(GroupingHandlerConfiguration.TYPE.LOCAL, 0); + setUpGroupHandler(GroupingHandlerConfiguration.TYPE.REMOTE, 1); + setUpGroupHandler(GroupingHandlerConfiguration.TYPE.REMOTE, 2); setupSessionFactory(0, isNetty()); setupSessionFactory(1, isNetty()); @@ -665,13 +665,14 @@ sendInRange(2, "queues.testaddress", 10, 20, false, MessageImpl.HDR_GROUP_ID, new SimpleString("id1")); - sendInRange(0, "queues.testaddress", 20, 30, false, MessageImpl.HDR_GROUP_ID, new SimpleString("id1")); - addConsumer(1, 1, "queue0", null); waitForBindings(1, "queues.testaddress", 1, 1, true); verifyReceiveAllInRange(10, 20, 1); + + + sendInRange(0, "queues.testaddress", 20, 30, false, MessageImpl.HDR_GROUP_ID, new SimpleString("id1")); verifyReceiveAllInRange(20, 30, 1); System.out.println("*****************************************************************************"); @@ -702,9 +703,9 @@ try { - setUpGroupArbitrator(GroupingHandlerConfiguration.TYPE.LOCAL, 0); - setUpGroupArbitrator(GroupingHandlerConfiguration.TYPE.REMOTE, 1); - setUpGroupArbitrator(GroupingHandlerConfiguration.TYPE.REMOTE, 2); + setUpGroupHandler(GroupingHandlerConfiguration.TYPE.LOCAL, 0); + setUpGroupHandler(GroupingHandlerConfiguration.TYPE.REMOTE, 1); + setUpGroupHandler(GroupingHandlerConfiguration.TYPE.REMOTE, 2); setupSessionFactory(0, isNetty()); setupSessionFactory(1, isNetty()); @@ -771,9 +772,9 @@ try { - setUpGroupArbitrator(GroupingHandlerConfiguration.TYPE.LOCAL, 0); - setUpGroupArbitrator(GroupingHandlerConfiguration.TYPE.REMOTE, 1); - setUpGroupArbitrator(GroupingHandlerConfiguration.TYPE.REMOTE, 2); + setUpGroupHandler(GroupingHandlerConfiguration.TYPE.LOCAL, 0); + setUpGroupHandler(GroupingHandlerConfiguration.TYPE.REMOTE, 1); + setUpGroupHandler(GroupingHandlerConfiguration.TYPE.REMOTE, 2); setupSessionFactory(0, isNetty()); setupSessionFactory(1, isNetty()); Deleted: branches/hornetq_grouping/tests/src/org/hornetq/tests/unit/core/postoffice/impl/BindingImplTest.java =================================================================== --- branches/hornetq_grouping/tests/src/org/hornetq/tests/unit/core/postoffice/impl/BindingImplTest.java 2009-10-14 10:00:17 UTC (rev 8104) +++ branches/hornetq_grouping/tests/src/org/hornetq/tests/unit/core/postoffice/impl/BindingImplTest.java 2009-10-14 10:13:49 UTC (rev 8105) @@ -1,1517 +0,0 @@ -/* - * Copyright 2009 Red Hat, Inc. - * Red Hat 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.hornetq.tests.unit.core.postoffice.impl; - -import java.io.InputStream; -import java.util.Collections; -import java.util.Iterator; -import java.util.List; -import java.util.Map; -import java.util.Set; -import java.util.concurrent.Executor; - -import javax.transaction.xa.Xid; - -import org.hornetq.core.exception.HornetQException; -import org.hornetq.core.filter.Filter; -import org.hornetq.core.postoffice.Binding; -import org.hornetq.core.postoffice.BindingType; -import org.hornetq.core.postoffice.impl.BindingsImpl; -import org.hornetq.core.remoting.Channel; -import org.hornetq.core.remoting.spi.HornetQBuffer; -import org.hornetq.core.server.Bindable; -import org.hornetq.core.server.Consumer; -import org.hornetq.core.server.Distributor; -import org.hornetq.core.server.MessageReference; -import org.hornetq.core.server.Queue; -import org.hornetq.core.server.ServerMessage; -import org.hornetq.core.transaction.Transaction; -import org.hornetq.core.transaction.TransactionOperation; -import org.hornetq.tests.util.UnitTestCase; -import org.hornetq.tests.unit.core.server.impl.fakes.FakePostOffice; -import org.hornetq.utils.SimpleString; -import org.hornetq.utils.TypedProperties; - -/** - * A BindingImplTest - * - * @author clebert - * - * Created Mar 12, 2009 9:14:46 PM - * - * - */ -public class BindingImplTest extends UnitTestCase -{ - - // Constants ----------------------------------------------------- - - // Attributes ---------------------------------------------------- - - // Static -------------------------------------------------------- - - // Constructors -------------------------------------------------- - - // Public -------------------------------------------------------- - - public void testRemoveWhileRouting() throws Exception - { - // It would require many iterations before getting a failure - for (int i = 0; i < 500; i++) - { - internalTest(true); - } - } - - public void testRemoveWhileRedistributing() throws Exception - { - // It would require many iterations before getting a failure - for (int i = 0; i < 500; i++) - { - internalTest(false); - } - } - - private void internalTest(final boolean route) throws Exception - { - final FakeBinding fake = new FakeBinding(new SimpleString("a")); - - final BindingsImpl bind = new BindingsImpl(new FakePostOffice()); - bind.addBinding(fake); - bind.addBinding(new FakeBinding(new SimpleString("a"))); - bind.addBinding(new FakeBinding(new SimpleString("a"))); - - Thread t = new Thread() - { - @Override - public void run() - { - try - { - bind.removeBinding(fake); - } - catch (Exception e) - { - e.printStackTrace(); - } - } - }; - - Queue queue = new FakeQueue(new SimpleString("a")); - t.start(); - - for (int i = 0; i < 100; i++) - { - if (route) - { - bind.route(new FakeMessage(), new FakeTransaction()); - } - else - { - bind.redistribute(new FakeMessage(), queue, new FakeTransaction()); - } - } - } - - class FakeTransaction implements Transaction - { - - /* (non-Javadoc) - * @see org.hornetq.core.transaction.Transaction#addOperation(org.hornetq.core.transaction.TransactionOperation) - */ - public void addOperation(final TransactionOperation sync) - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.transaction.Transaction#commit() - */ - public void commit() throws Exception - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.transaction.Transaction#commit(boolean) - */ - public void commit(final boolean onePhase) throws Exception - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.transaction.Transaction#getCreateTime() - */ - public long getCreateTime() - { - - return 0; - } - - /* (non-Javadoc) - * @see org.hornetq.core.transaction.Transaction#getID() - */ - public long getID() - { - - return 0; - } - - /* (non-Javadoc) - * @see org.hornetq.core.transaction.Transaction#getOperationsCount() - */ - public int getOperationsCount() - { - - return 0; - } - - /* (non-Javadoc) - * @see org.hornetq.core.transaction.Transaction#getProperty(int) - */ - public Object getProperty(final int index) - { - - return null; - } - - /* (non-Javadoc) - * @see org.hornetq.core.transaction.Transaction#getState() - */ - public State getState() - { - - return null; - } - - /* (non-Javadoc) - * @see org.hornetq.core.transaction.Transaction#getXid() - */ - public Xid getXid() - { - - return null; - } - - /* (non-Javadoc) - * @see org.hornetq.core.transaction.Transaction#markAsRollbackOnly(org.hornetq.core.exception.HornetQException) - */ - public void markAsRollbackOnly(final HornetQException exception) - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.transaction.Transaction#prepare() - */ - public void prepare() throws Exception - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.transaction.Transaction#putProperty(int, java.lang.Object) - */ - public void putProperty(final int index, final Object property) - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.transaction.Transaction#removeOperation(org.hornetq.core.transaction.TransactionOperation) - */ - public void removeOperation(final TransactionOperation sync) - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.transaction.Transaction#resume() - */ - public void resume() - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.transaction.Transaction#rollback() - */ - public void rollback() throws Exception - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.transaction.Transaction#setState(org.hornetq.core.transaction.Transaction.State) - */ - public void setState(final State state) - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.transaction.Transaction#suspend() - */ - public void suspend() - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.transaction.Transaction#getDistinctQueues() - */ - public Set<Queue> getDistinctQueues() - { - return Collections.emptySet(); - } - - } - - class FakeMessage implements ServerMessage - { - - public Map<String, Object> toMap() - { - return null; - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.ServerMessage#copy(long) - */ - public ServerMessage copy(final long newID) throws Exception - { - - return null; - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.ServerMessage#copy() - */ - public ServerMessage copy() throws Exception - { - - return null; - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.ServerMessage#createReference(org.hornetq.core.server.Queue) - */ - public MessageReference createReference(final Queue queue) - { - - return null; - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.ServerMessage#decrementDurableRefCount() - */ - public int decrementDurableRefCount() - { - - return 0; - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.ServerMessage#decrementRefCount() - */ - public int decrementRefCount() - { - - return 0; - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.ServerMessage#getMemoryEstimate() - */ - public int getMemoryEstimate() - { - - return 0; - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.ServerMessage#getRefCount() - */ - public int getRefCount() - { - - return 0; - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.ServerMessage#incrementDurableRefCount() - */ - public int incrementDurableRefCount() - { - - return 0; - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.ServerMessage#incrementRefCount() - */ - public int incrementRefCount() - { - - return 0; - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.ServerMessage#isLargeMessage() - */ - public boolean isLargeMessage() - { - - return false; - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.ServerMessage#isStored() - */ - public boolean isStored() - { - - return false; - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.ServerMessage#setMessageID(long) - */ - public void setMessageID(final long id) - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.ServerMessage#setStored() - */ - public void setStored() - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#containsProperty(org.hornetq.utils.SimpleString) - */ - public boolean containsProperty(final SimpleString key) - { - - return false; - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#decode(org.hornetq.core.remoting.spi.HornetQBuffer) - */ - public void decode(final HornetQBuffer buffer) - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#decodeBody(org.hornetq.core.remoting.spi.HornetQBuffer) - */ - public void decodeBody(final HornetQBuffer buffer) - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#decodeProperties(org.hornetq.core.remoting.spi.HornetQBuffer) - */ - public void decodeProperties(final HornetQBuffer buffer) - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#encode(org.hornetq.core.remoting.spi.HornetQBuffer) - */ - public void encode(final HornetQBuffer buffer) - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#encodeBody(org.hornetq.core.remoting.spi.HornetQBuffer, long, int) - */ - public void encodeBody(final HornetQBuffer buffer, final long start, final int size) - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#encodeBody(org.hornetq.core.remoting.spi.HornetQBuffer) - */ - public void encodeBody(final HornetQBuffer buffer) - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#encodeProperties(org.hornetq.core.remoting.spi.HornetQBuffer) - */ - public void encodeProperties(final HornetQBuffer buffer) - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#getBody() - */ - public HornetQBuffer getBody() - { - - return null; - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#getBodySize() - */ - public int getBodySize() - { - - return 0; - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#getDestination() - */ - public SimpleString getDestination() - { - - return null; - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#getEncodeSize() - */ - public int getEncodeSize() - { - - return 0; - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#getExpiration() - */ - public long getExpiration() - { - - return 0; - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#getMessageID() - */ - public long getMessageID() - { - - return 0; - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#getPriority() - */ - public byte getPriority() - { - - return 0; - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#getProperties() - */ - public TypedProperties getProperties() - { - - return null; - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#getPropertiesEncodeSize() - */ - public int getPropertiesEncodeSize() - { - - return 0; - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#getProperty(org.hornetq.utils.SimpleString) - */ - public Object getProperty(final SimpleString key) - { - - return null; - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#getPropertyNames() - */ - public Set<SimpleString> getPropertyNames() - { - - return null; - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#getTimestamp() - */ - public long getTimestamp() - { - - return 0; - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#getType() - */ - public byte getType() - { - - return 0; - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#isDurable() - */ - public boolean isDurable() - { - - return false; - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#isExpired() - */ - public boolean isExpired() - { - - return false; - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#putBooleanProperty(org.hornetq.utils.SimpleString, boolean) - */ - public void putBooleanProperty(final SimpleString key, final boolean value) - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#putByteProperty(org.hornetq.utils.SimpleString, byte) - */ - public void putByteProperty(final SimpleString key, final byte value) - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#putBytesProperty(org.hornetq.utils.SimpleString, byte[]) - */ - public void putBytesProperty(final SimpleString key, final byte[] value) - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#putDoubleProperty(org.hornetq.utils.SimpleString, double) - */ - public void putDoubleProperty(final SimpleString key, final double value) - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#putFloatProperty(org.hornetq.utils.SimpleString, float) - */ - public void putFloatProperty(final SimpleString key, final float value) - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#putIntProperty(org.hornetq.utils.SimpleString, int) - */ - public void putIntProperty(final SimpleString key, final int value) - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#putLongProperty(org.hornetq.utils.SimpleString, long) - */ - public void putLongProperty(final SimpleString key, final long value) - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#putShortProperty(org.hornetq.utils.SimpleString, short) - */ - public void putShortProperty(final SimpleString key, final short value) - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#putStringProperty(org.hornetq.utils.SimpleString, org.hornetq.utils.SimpleString) - */ - public void putStringProperty(final SimpleString key, final SimpleString value) - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#putTypedProperties(org.hornetq.utils.TypedProperties) - */ - public void putTypedProperties(final TypedProperties properties) - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#removeProperty(org.hornetq.utils.SimpleString) - */ - public Object removeProperty(final SimpleString key) - { - - return null; - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#setBody(org.hornetq.core.remoting.spi.HornetQBuffer) - */ - public void setBody(final HornetQBuffer body) - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#setDestination(org.hornetq.utils.SimpleString) - */ - public void setDestination(final SimpleString destination) - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#setDurable(boolean) - */ - public void setDurable(final boolean durable) - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#setExpiration(long) - */ - public void setExpiration(final long expiration) - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#setPriority(byte) - */ - public void setPriority(final byte priority) - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#setTimestamp(long) - */ - public void setTimestamp(final long timestamp) - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#getBodyInputStream() - */ - public InputStream getBodyInputStream() - { - return null; - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#setBodyInputStream(java.io.InputStream) - */ - public void setBodyInputStream(InputStream stream) - { - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#getLargeBodySize() - */ - public long getLargeBodySize() - { - return 0; - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#containsProperty(java.lang.String) - */ - public boolean containsProperty(String key) - { - - return false; - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#getProperty(java.lang.String) - */ - public Object getProperty(String key) - { - - return null; - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#putBooleanProperty(java.lang.String, boolean) - */ - public void putBooleanProperty(String key, boolean value) - { - - - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#putByteProperty(java.lang.String, byte) - */ - public void putByteProperty(String key, byte value) - { - - - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#putBytesProperty(java.lang.String, byte[]) - */ - public void putBytesProperty(String key, byte[] value) - { - - - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#putDoubleProperty(java.lang.String, double) - */ - public void putDoubleProperty(String key, double value) - { - - - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#putFloatProperty(java.lang.String, float) - */ - public void putFloatProperty(String key, float value) - { - - - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#putIntProperty(java.lang.String, int) - */ - public void putIntProperty(String key, int value) - { - - - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#putLongProperty(java.lang.String, long) - */ - public void putLongProperty(String key, long value) - { - - - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#putShortProperty(java.lang.String, short) - */ - public void putShortProperty(String key, short value) - { - - - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#putStringProperty(java.lang.String, java.lang.String) - */ - public void putStringProperty(String key, String value) - { - - - } - - /* (non-Javadoc) - * @see org.hornetq.core.message.Message#removeProperty(java.lang.String) - */ - public Object removeProperty(String key) - { - - return null; - } - - } - - class FakeFilter implements Filter - { - - /* (non-Javadoc) - * @see org.hornetq.core.filter.Filter#getFilterString() - */ - public SimpleString getFilterString() - { - return null; - } - - /* (non-Javadoc) - * @see org.hornetq.core.filter.Filter#match(org.hornetq.core.server.ServerMessage) - */ - public boolean match(final ServerMessage message) - { - return false; - } - - } - - class FakeBinding implements Binding - { - - final SimpleString name; - - FakeBinding(final SimpleString name) - { - this.name = name; - } - - public SimpleString getAddress() - { - - return null; - } - - /* (non-Javadoc) - * @see org.hornetq.core.postoffice.Binding#getBindable() - */ - public Bindable getBindable() - { - - return null; - } - - /* (non-Javadoc) - * @see org.hornetq.core.postoffice.Binding#getClusterName() - */ - public SimpleString getClusterName() - { - - return null; - } - - /* (non-Javadoc) - * @see org.hornetq.core.postoffice.Binding#getDistance() - */ - public int getDistance() - { - - return 0; - } - - /* (non-Javadoc) - * @see org.hornetq.core.postoffice.Binding#getFilter() - */ - public Filter getFilter() - { - return new FakeFilter(); - } - - /* (non-Javadoc) - * @see org.hornetq.core.postoffice.Binding#getID() - */ - public int getID() - { - - return 0; - } - - /* (non-Javadoc) - * @see org.hornetq.core.postoffice.Binding#getRoutingName() - */ - public SimpleString getRoutingName() - { - return name; - } - - /* (non-Javadoc) - * @see org.hornetq.core.postoffice.Binding#getType() - */ - public BindingType getType() - { - - return null; - } - - /* (non-Javadoc) - * @see org.hornetq.core.postoffice.Binding#getUniqueName() - */ - public SimpleString getUniqueName() - { - - return null; - } - - /* (non-Javadoc) - * @see org.hornetq.core.postoffice.Binding#isExclusive() - */ - public boolean isExclusive() - { - - return false; - } - - /* (non-Javadoc) - * @see org.hornetq.core.postoffice.Binding#isHighAcceptPriority(org.hornetq.core.server.ServerMessage) - */ - public boolean isHighAcceptPriority(final ServerMessage message) - { - - return false; - } - - /* (non-Javadoc) - * @see org.hornetq.core.postoffice.Binding#setID(int) - */ - public void setID(final int id) - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.postoffice.Binding#willRoute(org.hornetq.core.server.ServerMessage) - */ - public void willRoute(final ServerMessage message) - { - - } - - } - - class FakeQueue implements Queue - { - private SimpleString name; - - FakeQueue(SimpleString name) - { - this.name = name; - } - - public void setExpiryAddress(SimpleString expiryAddress) - { - // TODO Auto-generated method stub - - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#acknowledge(org.hornetq.core.server.MessageReference) - */ - public void acknowledge(MessageReference ref) throws Exception - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#acknowledge(org.hornetq.core.transaction.Transaction, org.hornetq.core.server.MessageReference) - */ - public void acknowledge(Transaction tx, MessageReference ref) throws Exception - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#activate() - */ - public boolean activate() - { - - return false; - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#activateNow(java.util.concurrent.Executor) - */ - public void activateNow(Executor executor) - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#addConsumer(org.hornetq.core.server.Consumer) - */ - public void addConsumer(Consumer consumer) throws Exception - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#addFirst(org.hornetq.core.server.MessageReference) - */ - public void addFirst(MessageReference ref) - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#addLast(org.hornetq.core.server.MessageReference) - */ - public void addLast(MessageReference ref) - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#addRedistributor(long, java.util.concurrent.Executor, org.hornetq.core.remoting.Channel) - */ - public void addRedistributor(long delay, Executor executor, Channel replicatingChannel) - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#cancel(org.hornetq.core.transaction.Transaction, org.hornetq.core.server.MessageReference) - */ - public void cancel(Transaction tx, MessageReference ref) throws Exception - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#cancel(org.hornetq.core.server.MessageReference) - */ - public void cancel(MessageReference reference) throws Exception - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#cancelRedistributor() - */ - public void cancelRedistributor() throws Exception - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#changeReferencePriority(long, byte) - */ - public boolean changeReferencePriority(long messageID, byte newPriority) throws Exception - { - - return false; - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#checkDLQ(org.hornetq.core.server.MessageReference) - */ - public boolean checkDLQ(MessageReference ref) throws Exception - { - - return false; - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#consumerFailedOver() - */ - public boolean consumerFailedOver() - { - - return false; - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#deleteAllReferences() - */ - public int deleteAllReferences() throws Exception - { - - return 0; - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#deleteMatchingReferences(org.hornetq.core.filter.Filter) - */ - public int deleteMatchingReferences(Filter filter) throws Exception - { - - return 0; - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#deleteReference(long) - */ - public boolean deleteReference(long messageID) throws Exception - { - - return false; - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#deliverAsync(java.util.concurrent.Executor) - */ - public void deliverAsync(Executor executor) - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#deliverNow() - */ - public void deliverNow() - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#expire(org.hornetq.core.server.MessageReference) - */ - public void expire(MessageReference ref) throws Exception - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#expireReference(long) - */ - public boolean expireReference(long messageID) throws Exception - { - - return false; - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#expireReferences(org.hornetq.core.filter.Filter) - */ - public int expireReferences(Filter filter) throws Exception - { - - return 0; - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#expireReferences() - */ - public void expireReferences() throws Exception - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#getConsumerCount() - */ - public int getConsumerCount() - { - - return 0; - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#getConsumers() - */ - public Set<Consumer> getConsumers() - { - - return null; - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#getDeliveringCount() - */ - public int getDeliveringCount() - { - - return 0; - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#getDistributionPolicy() - */ - public Distributor getDistributionPolicy() - { - - return null; - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#getFilter() - */ - public Filter getFilter() - { - - return null; - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#getMessageCount() - */ - public int getMessageCount() - { - - return 0; - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#getMessagesAdded() - */ - public int getMessagesAdded() - { - - return 0; - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#getName() - */ - public SimpleString getName() - { - return name; - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#getPersistenceID() - */ - public long getPersistenceID() - { - - return 0; - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#getReference(long) - */ - public MessageReference getReference(long id) - { - - return null; - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#getScheduledCount() - */ - public int getScheduledCount() - { - - return 0; - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#getScheduledMessages() - */ - public List<MessageReference> getScheduledMessages() - { - - return null; - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#isBackup() - */ - public boolean isBackup() - { - - return false; - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#isDurable() - */ - public boolean isDurable() - { - - return false; - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#isTemporary() - */ - public boolean isTemporary() - { - - return false; - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#list(org.hornetq.core.filter.Filter) - */ - public List<MessageReference> list(Filter filter) - { - - return null; - } - - public Iterator<MessageReference> iterator() - { - return null; - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#moveReference(long, org.hornetq.utils.SimpleString) - */ - public boolean moveReference(long messageID, SimpleString toAddress) throws Exception - { - - return false; - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#moveReferences(org.hornetq.core.filter.Filter, org.hornetq.utils.SimpleString) - */ - public int moveReferences(Filter filter, SimpleString toAddress) throws Exception - { - - return 0; - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#reacknowledge(org.hornetq.core.transaction.Transaction, org.hornetq.core.server.MessageReference) - */ - public void reacknowledge(Transaction tx, MessageReference ref) throws Exception - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#referenceHandled() - */ - public void referenceHandled() - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#removeConsumer(org.hornetq.core.server.Consumer) - */ - public boolean removeConsumer(Consumer consumer) throws Exception - { - - return false; - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#removeFirstReference(long) - */ - public MessageReference removeFirstReference(long id) throws Exception - { - - return null; - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#removeReferenceWithID(long) - */ - public MessageReference removeReferenceWithID(long id) throws Exception - { - - return null; - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#reroute(org.hornetq.core.server.ServerMessage, org.hornetq.core.transaction.Transaction) - */ - public MessageReference reroute(ServerMessage message, Transaction tx) throws Exception - { - - return null; - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#sendMessageToDeadLetterAddress(long) - */ - public boolean sendMessageToDeadLetterAddress(long messageID) throws Exception - { - - return false; - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#setBackup() - */ - public void setBackup() - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#setDistributionPolicy(org.hornetq.core.server.Distributor) - */ - public void setDistributionPolicy(Distributor policy) - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#setPersistenceID(long) - */ - public void setPersistenceID(long id) - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Bindable#preroute(org.hornetq.core.server.ServerMessage, org.hornetq.core.transaction.Transaction) - */ - public void preroute(ServerMessage message, Transaction tx) throws Exception - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Bindable#route(org.hornetq.core.server.ServerMessage, org.hornetq.core.transaction.Transaction) - */ - public void route(ServerMessage message, Transaction tx) throws Exception - { - - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#lock() - */ - public void lockDelivery() - { - } - - /* (non-Javadoc) - * @see org.hornetq.core.server.Queue#unlock() - */ - public void unlockDelivery() - { - } - - } - - // Package protected --------------------------------------------- - - // Protected ----------------------------------------------------- - - // Private ------------------------------------------------------- - - // Inner classes ------------------------------------------------- - -}