| /* |
| * 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.disttest.client; |
| |
| import java.util.Collections; |
| import java.util.Date; |
| |
| import javax.jms.DeliveryMode; |
| |
| import org.junit.Assert; |
| |
| import org.apache.qpid.disttest.message.ConsumerParticipantResult; |
| import org.apache.qpid.disttest.message.CreateConsumerCommand; |
| import org.apache.qpid.disttest.message.CreateParticipantCommand; |
| import org.apache.qpid.disttest.message.CreateProducerCommand; |
| import org.apache.qpid.disttest.message.ParticipantResult; |
| import org.apache.qpid.disttest.message.ProducerParticipantResult; |
| |
| import org.junit.Assert; |
| import org.junit.Before; |
| import org.junit.After; |
| import org.junit.Test; |
| |
| import org.apache.qpid.test.utils.UnitTestBase; |
| import static org.junit.Assert.assertSame; |
| import static org.junit.Assert.assertNotSame; |
| import static org.junit.Assert.fail; |
| import static org.junit.Assert.assertNotNull; |
| |
| import static org.junit.Assert.assertFalse; |
| import static org.junit.Assert.assertTrue; |
| |
| import static org.junit.Assert.assertEquals; |
| import static org.junit.Assert.assertNull; |
| |
| public class ParticipantResultFactoryTest extends UnitTestBase |
| { |
| private static final String PARTICIPANT_NAME = "participantName"; |
| private static final String REGISTERED_CLIENT_NAME = "registeredClientName"; |
| |
| private static final int BATCH_SIZE = 10; |
| private static final long MAXIMUM_DURATION = 500; |
| private static final int NUMBER_OF_MESSAGES_PROCESSED = 100; |
| private static final long TIME_TAKEN = 100; |
| private static final long TOTAL_PAYLOAD_PROCESSED = 200; |
| private static final int PAYLOAD_SIZE = 300; |
| |
| private static final Date START = new Date(0); |
| private static final Date END = new Date(START.getTime() + TIME_TAKEN); |
| |
| private static final String PROVIDER_VERSION = "1.0"; |
| private static final String PROTOCOL_VERSION = "MSS"; |
| |
| private ParticipantResultFactory _participantResultFactory; |
| |
| @Before |
| public void setUp() throws Exception |
| { |
| |
| _participantResultFactory = new ParticipantResultFactory(); |
| } |
| |
| @Test |
| public void testCreateForProducer() |
| { |
| CreateProducerCommand command = new CreateProducerCommand(); |
| setCommonCommandFields(command); |
| |
| int deliveryMode = DeliveryMode.PERSISTENT; |
| command.setDeliveryMode(deliveryMode); |
| |
| int priority = 5; |
| command.setPriority(priority); |
| |
| long producerInterval = 50; |
| command.setInterval(producerInterval); |
| |
| long timeToLive = 60; |
| command.setTimeToLive(timeToLive); |
| |
| int totalNumberOfConsumers = 0; |
| int totalNumberOfProducers = 1; |
| |
| int acknowledgeMode = 1; |
| |
| ProducerParticipantResult result = _participantResultFactory.createForProducer(PARTICIPANT_NAME, |
| REGISTERED_CLIENT_NAME, |
| command, |
| acknowledgeMode, |
| NUMBER_OF_MESSAGES_PROCESSED, |
| PAYLOAD_SIZE, |
| TOTAL_PAYLOAD_PROCESSED, |
| START, END, |
| PROVIDER_VERSION, |
| PROTOCOL_VERSION); |
| |
| assertCommonResultProperties(result); |
| |
| assertEquals((long) deliveryMode, (long) result.getDeliveryMode()); |
| assertEquals((long) acknowledgeMode, (long) result.getAcknowledgeMode()); |
| assertEquals((long) priority, (long) result.getPriority()); |
| assertEquals(producerInterval, result.getInterval()); |
| assertEquals(timeToLive, result.getTimeToLive()); |
| assertEquals((long) totalNumberOfConsumers, (long) result.getTotalNumberOfConsumers()); |
| } |
| |
| @Test |
| public void testCreateForConsumer() |
| { |
| CreateConsumerCommand command = new CreateConsumerCommand(); |
| setCommonCommandFields(command); |
| |
| boolean topic = true; |
| command.setTopic(topic); |
| |
| boolean durable = true; |
| command.setDurableSubscription(durable); |
| |
| boolean browsingSubscription = false; |
| command.setBrowsingSubscription(browsingSubscription); |
| |
| String selector = "selector"; |
| boolean isSelector = true; |
| command.setSelector(selector); |
| |
| boolean noLocal = false; |
| command.setNoLocal(noLocal); |
| |
| boolean synchronousConsumer = true; |
| command.setSynchronous(synchronousConsumer); |
| |
| int totalNumberOfConsumers = 1; |
| int totalNumberOfProducers = 0; |
| |
| int acknowledgeMode = 2; |
| |
| ConsumerParticipantResult result = _participantResultFactory.createForConsumer(PARTICIPANT_NAME, |
| REGISTERED_CLIENT_NAME, |
| command, |
| acknowledgeMode, |
| NUMBER_OF_MESSAGES_PROCESSED, |
| PAYLOAD_SIZE, |
| TOTAL_PAYLOAD_PROCESSED, |
| START, END, |
| Collections.<Long>emptyList(), |
| PROVIDER_VERSION, |
| PROTOCOL_VERSION); |
| |
| assertCommonResultProperties(result); |
| |
| assertEquals(topic, result.isTopic()); |
| assertEquals(durable, result.isDurableSubscription()); |
| assertEquals(browsingSubscription, result.isBrowsingSubscription()); |
| assertEquals(isSelector, result.isSelector()); |
| assertEquals(noLocal, result.isNoLocal()); |
| assertEquals(synchronousConsumer, result.isSynchronousConsumer()); |
| assertEquals((long) totalNumberOfConsumers, (long) result.getTotalNumberOfConsumers()); |
| assertEquals((long) totalNumberOfProducers, (long) result.getTotalNumberOfProducers()); |
| } |
| |
| @Test |
| public void testCreateForError() |
| { |
| String errorMessage = "error"; |
| ParticipantResult result = _participantResultFactory.createForError(PARTICIPANT_NAME, REGISTERED_CLIENT_NAME, errorMessage); |
| assertEquals(PARTICIPANT_NAME, result.getParticipantName()); |
| assertEquals(REGISTERED_CLIENT_NAME, result.getRegisteredClientName()); |
| } |
| |
| |
| private void setCommonCommandFields(CreateParticipantCommand command) |
| { |
| command.setBatchSize(BATCH_SIZE); |
| command.setMaximumDuration(MAXIMUM_DURATION); |
| } |
| |
| |
| private void assertCommonResultProperties(ParticipantResult result) |
| { |
| assertEquals(PARTICIPANT_NAME, result.getParticipantName()); |
| assertEquals(REGISTERED_CLIENT_NAME, result.getRegisteredClientName()); |
| assertEquals((long) BATCH_SIZE, (long) result.getBatchSize()); |
| assertEquals(MAXIMUM_DURATION, result.getMaximumDuration()); |
| assertEquals(TIME_TAKEN, result.getTimeTaken()); |
| assertEquals((long) NUMBER_OF_MESSAGES_PROCESSED, result.getNumberOfMessagesProcessed()); |
| assertEquals(TOTAL_PAYLOAD_PROCESSED, result.getTotalPayloadProcessed()); |
| assertEquals((long) PAYLOAD_SIZE, (long) result.getPayloadSize()); |
| assertEquals(PROVIDER_VERSION, result.getProviderVersion()); |
| assertEquals(PROTOCOL_VERSION, result.getProtocolVersion()); |
| } |
| |
| } |