CloudhopperSMPPSender.java

package fr.sii.ogham.sms.sender.impl;

import static fr.sii.ogham.core.util.LogUtils.logString;
import static fr.sii.ogham.sms.CloudhopperConstants.DEFAULT_CLOUDHOPPER_IMPLEMENTATION_PRIORITY;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.cloudhopper.smpp.SmppSession;
import com.cloudhopper.smpp.pdu.SubmitSm;
import com.cloudhopper.smpp.type.RecoverablePduException;
import com.cloudhopper.smpp.type.SmppChannelException;
import com.cloudhopper.smpp.type.SmppTimeoutException;
import com.cloudhopper.smpp.type.UnrecoverablePduException;

import fr.sii.ogham.core.builder.priority.Priority;
import fr.sii.ogham.core.clean.Cleanable;
import fr.sii.ogham.core.exception.MessageException;
import fr.sii.ogham.core.exception.clean.CleanException;
import fr.sii.ogham.core.sender.AbstractSpecializedSender;
import fr.sii.ogham.sms.message.Sms;
import fr.sii.ogham.sms.sender.impl.cloudhopper.ExtendedSmppSessionConfiguration;
import fr.sii.ogham.sms.sender.impl.cloudhopper.exception.SmppException;
import fr.sii.ogham.sms.sender.impl.cloudhopper.preparator.MessagePreparator;
import fr.sii.ogham.sms.sender.impl.cloudhopper.session.SessionHandlingStrategy;

/**
 * Implementation based on
 * <a href="https://github.com/twitter/cloudhopper-smpp">cloudhopper-smpp</a>
 * library.
 * 
 * @author Aurélien Baudet
 */
@Priority(properties="${ogham.sms.implementation-priority.cloudhopper}", defaultValue = DEFAULT_CLOUDHOPPER_IMPLEMENTATION_PRIORITY)
public class CloudhopperSMPPSender extends AbstractSpecializedSender<Sms> implements Cleanable {
	private static final Logger LOG = LoggerFactory.getLogger(CloudhopperSMPPSender.class);
	
	private final ExtendedSmppSessionConfiguration configuration;
	private final SessionHandlingStrategy sessionHandler;
	private final MessagePreparator messagePreparator;
	

	public CloudhopperSMPPSender(ExtendedSmppSessionConfiguration configuration, SessionHandlingStrategy sessionHandler, MessagePreparator messagePreparator) {
		super();
		this.configuration = configuration;
		this.sessionHandler = sessionHandler;
		this.messagePreparator = messagePreparator;
	}

	@Override
	public void send(Sms sms) throws MessageException {
		try {
			LOG.debug("Sending SMS...\n{}", logString(sms));
			SmppSession session = sessionHandler.getSession();
			for (SubmitSm msg : messagePreparator.prepareMessages(sms)) {
				session.submit(msg, configuration.getResponseTimeout());
			}
			LOG.debug("SMS sent\n{}", logString(sms));
			sessionHandler.messageSent(sms);
		} catch (SmppException e) {
			sessionHandler.messageNotSent(sms, e);
		} catch (UnrecoverablePduException | RecoverablePduException | SmppTimeoutException | SmppChannelException e) {
			sessionHandler.messageNotSent(sms, new SmppException("Failed to send SMS", e));
		} catch (InterruptedException e) {
			Thread.currentThread().interrupt();
			sessionHandler.messageNotSent(sms, new SmppException("Failed to send SMS (interrupted)", e));
		} finally {
			sessionHandler.messageProcessed(sms);
		}
	}

	@Override
	public void clean() throws CleanException {
		sessionHandler.clean();
	}

	@Override
	public String toString() {
		return "CloudhopperSMPPSender";
	}
}










Active mutators

org.pitest.mutationtest.engine.gregor.mutators.BooleanFalseReturnValsMutator
org.pitest.mutationtest.engine.gregor.mutators.BooleanTrueReturnValsMutator
org.pitest.mutationtest.engine.gregor.mutators.ConditionalsBoundaryMutator
org.pitest.mutationtest.engine.gregor.mutators.EmptyObjectReturnValsMutator
org.pitest.mutationtest.engine.gregor.mutators.IncrementsMutator
org.pitest.mutationtest.engine.gregor.mutators.InvertNegsMutator
org.pitest.mutationtest.engine.gregor.mutators.MathMutator
org.pitest.mutationtest.engine.gregor.mutators.NegateConditionalsMutator
org.pitest.mutationtest.engine.gregor.mutators.NullReturnValsMutator
org.pitest.mutationtest.engine.gregor.mutators.PrimitiveReturnsMutator
org.pitest.mutationtest.engine.gregor.mutators.VoidMethodCallMutator

Tests examined

Report generated by PIT OGHAM

1		package fr.sii.ogham.sms.sender.impl;
2
3		import static fr.sii.ogham.core.util.LogUtils.logString;
4		import static fr.sii.ogham.sms.CloudhopperConstants.DEFAULT_CLOUDHOPPER_IMPLEMENTATION_PRIORITY;
5
6		import org.slf4j.Logger;
7		import org.slf4j.LoggerFactory;
8
9		import com.cloudhopper.smpp.SmppSession;
10		import com.cloudhopper.smpp.pdu.SubmitSm;
11		import com.cloudhopper.smpp.type.RecoverablePduException;
12		import com.cloudhopper.smpp.type.SmppChannelException;
13		import com.cloudhopper.smpp.type.SmppTimeoutException;
14		import com.cloudhopper.smpp.type.UnrecoverablePduException;
15
16		import fr.sii.ogham.core.builder.priority.Priority;
17		import fr.sii.ogham.core.clean.Cleanable;
18		import fr.sii.ogham.core.exception.MessageException;
19		import fr.sii.ogham.core.exception.clean.CleanException;
20		import fr.sii.ogham.core.sender.AbstractSpecializedSender;
21		import fr.sii.ogham.sms.message.Sms;
22		import fr.sii.ogham.sms.sender.impl.cloudhopper.ExtendedSmppSessionConfiguration;
23		import fr.sii.ogham.sms.sender.impl.cloudhopper.exception.SmppException;
24		import fr.sii.ogham.sms.sender.impl.cloudhopper.preparator.MessagePreparator;
25		import fr.sii.ogham.sms.sender.impl.cloudhopper.session.SessionHandlingStrategy;
26
27		/**
28		* Implementation based on
29		* <a href="https://github.com/twitter/cloudhopper-smpp">cloudhopper-smpp</a>
30		* library.
31		*
32		* @author Aurélien Baudet
33		*/
34		@Priority(properties="${ogham.sms.implementation-priority.cloudhopper}", defaultValue = DEFAULT_CLOUDHOPPER_IMPLEMENTATION_PRIORITY)
35		public class CloudhopperSMPPSender extends AbstractSpecializedSender<Sms> implements Cleanable {
36		private static final Logger LOG = LoggerFactory.getLogger(CloudhopperSMPPSender.class);
37
38		private final ExtendedSmppSessionConfiguration configuration;
39		private final SessionHandlingStrategy sessionHandler;
40		private final MessagePreparator messagePreparator;
41
42
43		public CloudhopperSMPPSender(ExtendedSmppSessionConfiguration configuration, SessionHandlingStrategy sessionHandler, MessagePreparator messagePreparator) {
44		super();
45		this.configuration = configuration;
46		this.sessionHandler = sessionHandler;
47		this.messagePreparator = messagePreparator;
48		}
49
50		@Override
51		public void send(Sms sms) throws MessageException {
52		try {
53		LOG.debug("Sending SMS...\n{}", logString(sms));
54		SmppSession session = sessionHandler.getSession();
55		for (SubmitSm msg : messagePreparator.prepareMessages(sms)) {
56		session.submit(msg, configuration.getResponseTimeout());
57		}
58		LOG.debug("SMS sent\n{}", logString(sms));
59	4 1. send : removed call to fr/sii/ogham/sms/sender/impl/cloudhopper/session/SessionHandlingStrategy::messageSent → NO_COVERAGE 2. send : removed call to fr/sii/ogham/sms/sender/impl/cloudhopper/session/SessionHandlingStrategy::messageSent → SURVIVED 3. send : removed call to fr/sii/ogham/sms/sender/impl/cloudhopper/session/SessionHandlingStrategy::messageSent → SURVIVED 4. send : removed call to fr/sii/ogham/sms/sender/impl/cloudhopper/session/SessionHandlingStrategy::messageSent → TIMED_OUT	sessionHandler.messageSent(sms);
60		} catch (SmppException e) {
61	3 1. send : removed call to fr/sii/ogham/sms/sender/impl/cloudhopper/session/SessionHandlingStrategy::messageNotSent → NO_COVERAGE 2. send : removed call to fr/sii/ogham/sms/sender/impl/cloudhopper/session/SessionHandlingStrategy::messageNotSent → KILLED 3. send : removed call to fr/sii/ogham/sms/sender/impl/cloudhopper/session/SessionHandlingStrategy::messageNotSent → KILLED	sessionHandler.messageNotSent(sms, e);
62		} catch (UnrecoverablePduException \| RecoverablePduException \| SmppTimeoutException \| SmppChannelException e) {
63	2 1. send : removed call to fr/sii/ogham/sms/sender/impl/cloudhopper/session/SessionHandlingStrategy::messageNotSent → NO_COVERAGE 2. send : removed call to fr/sii/ogham/sms/sender/impl/cloudhopper/session/SessionHandlingStrategy::messageNotSent → KILLED	sessionHandler.messageNotSent(sms, new SmppException("Failed to send SMS", e));
64		} catch (InterruptedException e) {
65	1 1. send : removed call to java/lang/Thread::interrupt → NO_COVERAGE	Thread.currentThread().interrupt();
66	1 1. send : removed call to fr/sii/ogham/sms/sender/impl/cloudhopper/session/SessionHandlingStrategy::messageNotSent → NO_COVERAGE	sessionHandler.messageNotSent(sms, new SmppException("Failed to send SMS (interrupted)", e));
67		} finally {
68	4 1. send : removed call to fr/sii/ogham/sms/sender/impl/cloudhopper/session/SessionHandlingStrategy::messageProcessed → NO_COVERAGE 2. send : removed call to fr/sii/ogham/sms/sender/impl/cloudhopper/session/SessionHandlingStrategy::messageProcessed → SURVIVED 3. send : removed call to fr/sii/ogham/sms/sender/impl/cloudhopper/session/SessionHandlingStrategy::messageProcessed → TIMED_OUT 4. send : removed call to fr/sii/ogham/sms/sender/impl/cloudhopper/session/SessionHandlingStrategy::messageProcessed → KILLED	sessionHandler.messageProcessed(sms);
69		}
70		}
71
72		@Override
73		public void clean() throws CleanException {
74	4 1. clean : removed call to fr/sii/ogham/sms/sender/impl/cloudhopper/session/SessionHandlingStrategy::clean → SURVIVED 2. clean : removed call to fr/sii/ogham/sms/sender/impl/cloudhopper/session/SessionHandlingStrategy::clean → SURVIVED 3. clean : removed call to fr/sii/ogham/sms/sender/impl/cloudhopper/session/SessionHandlingStrategy::clean → TIMED_OUT 4. clean : removed call to fr/sii/ogham/sms/sender/impl/cloudhopper/session/SessionHandlingStrategy::clean → KILLED	sessionHandler.clean();
75		}
76
77		@Override
78		public String toString() {
79	3 1. toString : replaced return value with "" for fr/sii/ogham/sms/sender/impl/CloudhopperSMPPSender::toString → SURVIVED 2. toString : replaced return value with "" for fr/sii/ogham/sms/sender/impl/CloudhopperSMPPSender::toString → SURVIVED 3. toString : replaced return value with "" for fr/sii/ogham/sms/sender/impl/CloudhopperSMPPSender::toString → TIMED_OUT	return "CloudhopperSMPPSender";
80		}
81		}
		Mutations
59		1.1 Location : send Killed by : none removed call to fr/sii/ogham/sms/sender/impl/cloudhopper/session/SessionHandlingStrategy::messageSent → NO_COVERAGE 2.2 Location : send Killed by : none removed call to fr/sii/ogham/sms/sender/impl/cloudhopper/session/SessionHandlingStrategy::messageSent → SURVIVED 3.3 Location : send Killed by : none removed call to fr/sii/ogham/sms/sender/impl/cloudhopper/session/SessionHandlingStrategy::messageSent → TIMED_OUT 4.4 Location : send Killed by : none removed call to fr/sii/ogham/sms/sender/impl/cloudhopper/session/SessionHandlingStrategy::messageSent → SURVIVED
61		1.1 Location : send Killed by : oghamall.it.retry.AutoRetryTest.resendSms(oghamall.it.retry.AutoRetryTest) removed call to fr/sii/ogham/sms/sender/impl/cloudhopper/session/SessionHandlingStrategy::messageNotSent → KILLED 2.2 Location : send Killed by : oghamcloudhopper.it.ConnectionFailureTest.invalidSystemId(oghamcloudhopper.it.ConnectionFailureTest) removed call to fr/sii/ogham/sms/sender/impl/cloudhopper/session/SessionHandlingStrategy::messageNotSent → KILLED 3.3 Location : send Killed by : none removed call to fr/sii/ogham/sms/sender/impl/cloudhopper/session/SessionHandlingStrategy::messageNotSent → NO_COVERAGE
63		1.1 Location : send Killed by : oghamcloudhopper.it.ReuseSessionStrategyTest.reuseSessionButSendFailsDueToSessionClosedByServer(oghamcloudhopper.it.ReuseSessionStrategyTest) removed call to fr/sii/ogham/sms/sender/impl/cloudhopper/session/SessionHandlingStrategy::messageNotSent → KILLED 2.2 Location : send Killed by : none removed call to fr/sii/ogham/sms/sender/impl/cloudhopper/session/SessionHandlingStrategy::messageNotSent → NO_COVERAGE
65		1.1 Location : send Killed by : none removed call to java/lang/Thread::interrupt → NO_COVERAGE
66		1.1 Location : send Killed by : none removed call to fr/sii/ogham/sms/sender/impl/cloudhopper/session/SessionHandlingStrategy::messageNotSent → NO_COVERAGE
68		1.1 Location : send Killed by : none removed call to fr/sii/ogham/sms/sender/impl/cloudhopper/session/SessionHandlingStrategy::messageProcessed → TIMED_OUT 2.2 Location : send Killed by : none removed call to fr/sii/ogham/sms/sender/impl/cloudhopper/session/SessionHandlingStrategy::messageProcessed → NO_COVERAGE 3.3 Location : send Killed by : oghamcloudhopper.it.AlwaysNewSessionStrategyTest.alwaysNewSession(oghamcloudhopper.it.AlwaysNewSessionStrategyTest) removed call to fr/sii/ogham/sms/sender/impl/cloudhopper/session/SessionHandlingStrategy::messageProcessed → KILLED 4.4 Location : send Killed by : none removed call to fr/sii/ogham/sms/sender/impl/cloudhopper/session/SessionHandlingStrategy::messageProcessed → SURVIVED
74		1.1 Location : clean Killed by : oghamcloudhopper.it.ReuseSessionStrategyTest.reuseSessionButEnquireLinkTimeout(oghamcloudhopper.it.ReuseSessionStrategyTest) removed call to fr/sii/ogham/sms/sender/impl/cloudhopper/session/SessionHandlingStrategy::clean → KILLED 2.2 Location : clean Killed by : none removed call to fr/sii/ogham/sms/sender/impl/cloudhopper/session/SessionHandlingStrategy::clean → SURVIVED 3.3 Location : clean Killed by : none removed call to fr/sii/ogham/sms/sender/impl/cloudhopper/session/SessionHandlingStrategy::clean → TIMED_OUT 4.4 Location : clean Killed by : none removed call to fr/sii/ogham/sms/sender/impl/cloudhopper/session/SessionHandlingStrategy::clean → SURVIVED
79		1.1 Location : toString Killed by : none replaced return value with "" for fr/sii/ogham/sms/sender/impl/CloudhopperSMPPSender::toString → SURVIVED 2.2 Location : toString Killed by : none replaced return value with "" for fr/sii/ogham/sms/sender/impl/CloudhopperSMPPSender::toString → SURVIVED 3.3 Location : toString Killed by : none replaced return value with "" for fr/sii/ogham/sms/sender/impl/CloudhopperSMPPSender::toString → TIMED_OUT

CloudhopperSMPPSender.java

Mutations

Active mutators

Tests examined