diff options
Diffstat (limited to 'qpid/java/broker-core/src/test/java/org/apache')
3 files changed, 18 insertions, 403 deletions
diff --git a/qpid/java/broker-core/src/test/java/org/apache/qpid/server/store/EventManagerTest.java b/qpid/java/broker-core/src/test/java/org/apache/qpid/server/store/EventManagerTest.java index 702874fb88..a9b2e0d961 100644 --- a/qpid/java/broker-core/src/test/java/org/apache/qpid/server/store/EventManagerTest.java +++ b/qpid/java/broker-core/src/test/java/org/apache/qpid/server/store/EventManagerTest.java @@ -22,8 +22,8 @@ package org.apache.qpid.server.store; import static org.mockito.Mockito.mock; import static org.mockito.Mockito.verify; import static org.mockito.Mockito.verifyZeroInteractions; -import static org.apache.qpid.server.store.Event.AFTER_ACTIVATE; -import static org.apache.qpid.server.store.Event.BEFORE_ACTIVATE; +import static org.apache.qpid.server.store.Event.PERSISTENT_MESSAGE_SIZE_UNDERFULL; +import static org.apache.qpid.server.store.Event.PERSISTENT_MESSAGE_SIZE_OVERFULL; import junit.framework.TestCase; public class EventManagerTest extends TestCase @@ -33,28 +33,28 @@ public class EventManagerTest extends TestCase public void testEventListenerFires() { - _eventManager.addEventListener(_mockListener, BEFORE_ACTIVATE); - _eventManager.notifyEvent(BEFORE_ACTIVATE); - verify(_mockListener).event(BEFORE_ACTIVATE); + _eventManager.addEventListener(_mockListener, PERSISTENT_MESSAGE_SIZE_OVERFULL); + _eventManager.notifyEvent(PERSISTENT_MESSAGE_SIZE_OVERFULL); + verify(_mockListener).event(PERSISTENT_MESSAGE_SIZE_OVERFULL); } public void testEventListenerDoesntFire() { - _eventManager.addEventListener(_mockListener, BEFORE_ACTIVATE); - _eventManager.notifyEvent(AFTER_ACTIVATE); + _eventManager.addEventListener(_mockListener, PERSISTENT_MESSAGE_SIZE_OVERFULL); + _eventManager.notifyEvent(Event.PERSISTENT_MESSAGE_SIZE_UNDERFULL); verifyZeroInteractions(_mockListener); } public void testEventListenerFiresMultipleTimes() { - _eventManager.addEventListener(_mockListener, BEFORE_ACTIVATE); - _eventManager.addEventListener(_mockListener, AFTER_ACTIVATE); + _eventManager.addEventListener(_mockListener, PERSISTENT_MESSAGE_SIZE_OVERFULL); + _eventManager.addEventListener(_mockListener, PERSISTENT_MESSAGE_SIZE_UNDERFULL); - _eventManager.notifyEvent(BEFORE_ACTIVATE); - verify(_mockListener).event(BEFORE_ACTIVATE); + _eventManager.notifyEvent(PERSISTENT_MESSAGE_SIZE_OVERFULL); + verify(_mockListener).event(PERSISTENT_MESSAGE_SIZE_OVERFULL); - _eventManager.notifyEvent(AFTER_ACTIVATE); - verify(_mockListener).event(AFTER_ACTIVATE); + _eventManager.notifyEvent(PERSISTENT_MESSAGE_SIZE_UNDERFULL); + verify(_mockListener).event(PERSISTENT_MESSAGE_SIZE_UNDERFULL); } public void testMultipleListenersFireForSameEvent() @@ -62,11 +62,11 @@ public class EventManagerTest extends TestCase final EventListener mockListener1 = mock(EventListener.class); final EventListener mockListener2 = mock(EventListener.class); - _eventManager.addEventListener(mockListener1, BEFORE_ACTIVATE); - _eventManager.addEventListener(mockListener2, BEFORE_ACTIVATE); - _eventManager.notifyEvent(BEFORE_ACTIVATE); + _eventManager.addEventListener(mockListener1, PERSISTENT_MESSAGE_SIZE_OVERFULL); + _eventManager.addEventListener(mockListener2, PERSISTENT_MESSAGE_SIZE_OVERFULL); + _eventManager.notifyEvent(PERSISTENT_MESSAGE_SIZE_OVERFULL); - verify(mockListener1).event(BEFORE_ACTIVATE); - verify(mockListener2).event(BEFORE_ACTIVATE); + verify(mockListener1).event(PERSISTENT_MESSAGE_SIZE_OVERFULL); + verify(mockListener2).event(PERSISTENT_MESSAGE_SIZE_OVERFULL); } } diff --git a/qpid/java/broker-core/src/test/java/org/apache/qpid/server/store/OperationalLoggingListenerTest.java b/qpid/java/broker-core/src/test/java/org/apache/qpid/server/store/OperationalLoggingListenerTest.java deleted file mode 100644 index aa9483a894..0000000000 --- a/qpid/java/broker-core/src/test/java/org/apache/qpid/server/store/OperationalLoggingListenerTest.java +++ /dev/null @@ -1,185 +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.store; - -import java.util.ArrayList; -import java.util.List; -import junit.framework.TestCase; -import org.apache.qpid.server.logging.EventLogger; -import org.apache.qpid.server.logging.LogMessage; -import org.apache.qpid.server.logging.LogSubject; -import org.apache.qpid.server.logging.MessageLogger; -import org.apache.qpid.server.logging.messages.ConfigStoreMessages; -import org.apache.qpid.server.logging.messages.MessageStoreMessages; -import org.apache.qpid.server.logging.messages.TransactionLogMessages; - -import static org.mockito.Mockito.mock; - -public class OperationalLoggingListenerTest extends TestCase -{ - - - public static final String STORE_LOCATION = "The moon!"; - private EventLogger _eventLogger; - - protected void setUp() throws Exception - { - super.setUp(); - _eventLogger = new EventLogger(); - } - - public void testOperationalLoggingWithStoreLocation() throws Exception - { - TestMessageStore messageStore = new TestMessageStore(); - LogSubject logSubject = LOG_SUBJECT; - - OperationalLoggingListener.listen(messageStore, logSubject, _eventLogger); - - performTests(messageStore, true); - - } - - public void testOperationalLogging() throws Exception - { - TestMessageStore messageStore = new TestMessageStore(); - LogSubject logSubject = LOG_SUBJECT; - - OperationalLoggingListener.listen(messageStore, logSubject, _eventLogger); - - performTests(messageStore, false); - } - - private void performTests(TestMessageStore messageStore, boolean setStoreLocation) - { - final List<LogMessage> messages = new ArrayList<LogMessage>(); - - _eventLogger.setMessageLogger(new TestLogger(messages)); - - if(setStoreLocation) - { - messageStore.setStoreLocation(STORE_LOCATION); - } - - - messageStore.attainState(State.INITIALISING); - assertEquals("Unexpected number of operational log messages on configuring", 1, messages.size()); - assertEquals(messages.remove(0).toString(), ConfigStoreMessages.CREATED().toString()); - - messageStore.attainState(State.INITIALISED); - assertEquals("Unexpected number of operational log messages on CONFIGURED", setStoreLocation ? 3 : 2, messages.size()); - assertEquals(messages.remove(0).toString(), MessageStoreMessages.CREATED().toString()); - assertEquals(messages.remove(0).toString(), TransactionLogMessages.CREATED().toString()); - if(setStoreLocation) - { - assertEquals(messages.remove(0).toString(), MessageStoreMessages.STORE_LOCATION(STORE_LOCATION).toString()); - } - - messageStore.attainState(State.ACTIVATING); - assertEquals("Unexpected number of operational log messages on RECOVERING", 1, messages.size()); - assertEquals(messages.remove(0).toString(), MessageStoreMessages.RECOVERY_START().toString()); - - - messageStore.attainState(State.ACTIVE); - assertEquals("Unexpected number of operational log messages on ACTIVE", 1, messages.size()); - assertEquals(messages.remove(0).toString(), MessageStoreMessages.RECOVERY_COMPLETE().toString()); - - messageStore.attainState(State.CLOSING); - assertEquals("Unexpected number of operational log messages on CLOSING", 0, messages.size()); - - messageStore.attainState(State.CLOSED); - assertEquals("Unexpected number of operational log messages on CLOSED", 1, messages.size()); - assertEquals(messages.remove(0).toString(), MessageStoreMessages.CLOSED().toString()); - } - - private static final LogSubject LOG_SUBJECT = new LogSubject() - { - public String toLogString() - { - return ""; - } - }; - - private static final class TestMessageStore extends NullMessageStore - { - - private final EventManager _eventManager = new EventManager(); - private final StateManager _stateManager = new StateManager(_eventManager); - private String _storeLocation; - - public void attainState(State state) - { - _stateManager.attainState(state); - } - - @Override - public String getStoreLocation() - { - return _storeLocation; - } - - public void setStoreLocation(String storeLocation) - { - _storeLocation = storeLocation; - } - - @Override - public void addEventListener(EventListener eventListener, Event... events) - { - _eventManager.addEventListener(eventListener, events); - } - - @Override - public String getStoreType() - { - return "TEST"; - } - } - - private static class TestLogger implements MessageLogger - { - private final List<LogMessage> _messages; - - private TestLogger(final List<LogMessage> messages) - { - _messages = messages; - } - - public void message(LogSubject subject, LogMessage message) - { - _messages.add(message); - } - - @Override - public boolean isEnabled() - { - return true; - } - - @Override - public boolean isMessageEnabled(final String logHierarchy) - { - return true; - } - - public void message(LogMessage message) - { - _messages.add(message); - } - - } - -} diff --git a/qpid/java/broker-core/src/test/java/org/apache/qpid/server/store/StateManagerTest.java b/qpid/java/broker-core/src/test/java/org/apache/qpid/server/store/StateManagerTest.java deleted file mode 100644 index 1996620950..0000000000 --- a/qpid/java/broker-core/src/test/java/org/apache/qpid/server/store/StateManagerTest.java +++ /dev/null @@ -1,200 +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.store; - - -import java.util.EnumSet; - -import junit.framework.TestCase; - -public class StateManagerTest extends TestCase implements EventListener -{ - - private StateManager _manager; - private Event _event; - - public void setUp() throws Exception - { - super.setUp(); - _manager = new StateManager(this); - } - - public void testInitialState() - { - assertEquals(State.INITIAL, _manager.getState()); - } - - public void testStateTransitionAllowed() - { - assertEquals(State.INITIAL, _manager.getState()); - - _manager.attainState(State.INITIALISING); - assertEquals(State.INITIALISING, _manager.getState()); - } - - public void testStateTransitionDisallowed() - { - assertEquals(State.INITIAL, _manager.getState()); - - try - { - _manager.attainState(State.CLOSING); - fail("Exception not thrown"); - } - catch (IllegalStateException e) - { - // PASS - } - assertEquals(State.INITIAL, _manager.getState()); - } - - public void testIsInState() - { - assertEquals(State.INITIAL, _manager.getState()); - assertFalse(_manager.isInState(State.ACTIVE)); - assertTrue(_manager.isInState(State.INITIAL)); - } - - public void testIsNotInState() - { - assertEquals(State.INITIAL, _manager.getState()); - assertTrue(_manager.isNotInState(State.ACTIVE)); - assertFalse(_manager.isNotInState(State.INITIAL)); - } - - public void testCheckInState() - { - assertEquals(State.INITIAL, _manager.getState()); - - try - { - _manager.checkInState(State.ACTIVE); - fail("Exception not thrown"); - } - catch (IllegalStateException e) - { - // PASS - } - assertEquals(State.INITIAL, _manager.getState()); - } - - public void testValidStateTransitions() - { - assertEquals(State.INITIAL, _manager.getState()); - performValidTransition(StateManager.INITIALISE); - performValidTransition(StateManager.INITIALISE_COMPLETE); - performValidTransition(StateManager.ACTIVATE); - performValidTransition(StateManager.ACTIVATE_COMPLETE); - performValidTransition(StateManager.QUIESCE); - performValidTransition(StateManager.QUIESCE_COMPLETE); - performValidTransition(StateManager.RESTART); - performValidTransition(StateManager.ACTIVATE_COMPLETE); - performValidTransition(StateManager.CLOSE_ACTIVE); - performValidTransition(StateManager.CLOSE_COMPLETE); - - _manager = new StateManager(this); - assertEquals(State.INITIAL, _manager.getState()); - performValidTransition(StateManager.INITIALISE); - performValidTransition(StateManager.INITIALISE_COMPLETE); - performValidTransition(StateManager.CLOSE_INITIALISED); - performValidTransition(StateManager.CLOSE_COMPLETE); - - _manager = new StateManager(this); - performValidTransition(StateManager.INITIALISE); - performValidTransition(StateManager.INITIALISE_COMPLETE); - performValidTransition(StateManager.ACTIVATE); - performValidTransition(StateManager.ACTIVATE_COMPLETE); - performValidTransition(StateManager.QUIESCE); - performValidTransition(StateManager.QUIESCE_COMPLETE); - performValidTransition(StateManager.CLOSE_QUIESCED); - performValidTransition(StateManager.CLOSE_COMPLETE); - } - - private void performValidTransition(StateManager.Transition transition) - { - _manager.attainState(transition.getEndState()); - assertEquals("Unexpected end state", transition.getEndState(), _manager.getState()); - assertEquals("Unexpected event", transition.getEvent(), _event); - _event = null; - } - - public void testInvalidStateTransitions() - { - assertEquals(State.INITIAL, _manager.getState()); - - performInvalidTransitions(StateManager.INITIALISE, State.INITIALISED); - performInvalidTransitions(StateManager.INITIALISE_COMPLETE, State.ACTIVATING, State.CLOSING); - performInvalidTransitions(StateManager.ACTIVATE, State.ACTIVE, State.CLOSING); - performInvalidTransitions(StateManager.ACTIVATE_COMPLETE, State.QUIESCING, State.CLOSING, State.INITIALISED); - performInvalidTransitions(StateManager.QUIESCE, State.QUIESCED); - performInvalidTransitions(StateManager.QUIESCE_COMPLETE, State.ACTIVATING, State.CLOSING); - performInvalidTransitions(StateManager.CLOSE_QUIESCED, State.CLOSED); - performInvalidTransitions(StateManager.CLOSE_COMPLETE); - - } - - private void performInvalidTransitions(StateManager.Transition preTransition, State... validEndStates) - { - if(preTransition != null) - { - performValidTransition(preTransition); - } - - EnumSet<State> endStates = EnumSet.allOf(State.class); - - if(validEndStates != null) - { - for(State state: validEndStates) - { - endStates.remove(state); - } - } - - for(State invalidEndState : endStates) - { - performInvalidStateTransition(invalidEndState); - } - - - } - - private void performInvalidStateTransition(State invalidEndState) - { - try - { - _event = null; - State startState = _manager.getState(); - _manager.attainState(invalidEndState); - fail("Invalid state transition performed: " + startState + " to " + invalidEndState); - } - catch(IllegalStateException e) - { - // pass - } - assertNull("No event should have be fired", _event); - } - - @Override - public void event(Event event) - { - _event = event; - } -} |