| /* |
| * 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.camel.component.smpp; |
| |
| import java.util.Arrays; |
| import java.util.Date; |
| import java.util.LinkedHashMap; |
| import java.util.Map; |
| import java.util.TimeZone; |
| |
| import org.apache.camel.Exchange; |
| import org.apache.camel.ExchangePattern; |
| import org.apache.camel.impl.DefaultCamelContext; |
| import org.apache.camel.support.DefaultExchange; |
| import org.jsmpp.bean.Address; |
| import org.jsmpp.bean.Alphabet; |
| import org.jsmpp.bean.DataCodings; |
| import org.jsmpp.bean.ESMClass; |
| import org.jsmpp.bean.NumberingPlanIndicator; |
| import org.jsmpp.bean.OptionalParameter; |
| import org.jsmpp.bean.OptionalParameter.Tag; |
| import org.jsmpp.bean.RegisteredDelivery; |
| import org.jsmpp.bean.ReplaceIfPresentFlag; |
| import org.jsmpp.bean.SMSCDeliveryReceipt; |
| import org.jsmpp.bean.SubmitMultiResult; |
| import org.jsmpp.bean.TypeOfNumber; |
| import org.jsmpp.bean.UnsuccessDelivery; |
| import org.jsmpp.session.SMPPSession; |
| import org.junit.AfterClass; |
| import org.junit.Before; |
| import org.junit.BeforeClass; |
| import org.junit.Test; |
| |
| import static org.junit.Assert.assertEquals; |
| import static org.junit.Assert.assertNotNull; |
| import static org.junit.Assert.assertNull; |
| import static org.mockito.ArgumentMatchers.eq; |
| import static org.mockito.ArgumentMatchers.isNull; |
| import static org.mockito.Mockito.mock; |
| import static org.mockito.Mockito.when; |
| |
| public class SmppSubmitMultiCommandTest { |
| |
| private static TimeZone defaultTimeZone; |
| |
| private SMPPSession session; |
| private SmppConfiguration config; |
| private SmppSubmitMultiCommand command; |
| |
| @BeforeClass |
| public static void setUpBeforeClass() { |
| defaultTimeZone = TimeZone.getDefault(); |
| |
| TimeZone.setDefault(TimeZone.getTimeZone("GMT")); |
| } |
| |
| @AfterClass |
| public static void tearDownAfterClass() { |
| if (defaultTimeZone != null) { |
| TimeZone.setDefault(defaultTimeZone); |
| } |
| } |
| |
| @Before |
| public void setUp() { |
| session = mock(SMPPSession.class); |
| config = new SmppConfiguration(); |
| config.setServiceType("CMT"); |
| |
| command = new SmppSubmitMultiCommand(session, config); |
| } |
| |
| @Test |
| public void executeWithConfigurationData() throws Exception { |
| Exchange exchange = new DefaultExchange(new DefaultCamelContext(), ExchangePattern.InOut); |
| exchange.getIn().setHeader(SmppConstants.COMMAND, "SubmitMulti"); |
| exchange.getIn().setHeader(SmppConstants.ID, "1"); |
| exchange.getIn().setBody("short message body"); |
| when(session.submitMultiple(eq("CMT"), eq(TypeOfNumber.UNKNOWN), eq(NumberingPlanIndicator.UNKNOWN), eq("1616"), |
| eq(new Address[]{new Address(TypeOfNumber.UNKNOWN, NumberingPlanIndicator.UNKNOWN, "1717")}), |
| eq(new ESMClass()), eq((byte) 0), eq((byte) 1), (String) isNull(), (String) isNull(), eq(new RegisteredDelivery(SMSCDeliveryReceipt.SUCCESS_FAILURE)), |
| eq(ReplaceIfPresentFlag.DEFAULT), eq(DataCodings.newInstance((byte) 0)), eq((byte) 0), eq("short message body".getBytes()))) |
| .thenReturn(new SubmitMultiResult("1", new UnsuccessDelivery(new Address(TypeOfNumber.UNKNOWN, NumberingPlanIndicator.UNKNOWN, "1717"), 0))); |
| |
| command.execute(exchange); |
| |
| assertEquals(Arrays.asList("1"), exchange.getOut().getHeader(SmppConstants.ID)); |
| assertEquals(1, exchange.getOut().getHeader(SmppConstants.SENT_MESSAGE_COUNT)); |
| assertNotNull(exchange.getOut().getHeader(SmppConstants.ERROR)); |
| } |
| |
| @Test |
| public void execute() throws Exception { |
| Exchange exchange = new DefaultExchange(new DefaultCamelContext(), ExchangePattern.InOut); |
| exchange.getIn().setHeader(SmppConstants.COMMAND, "SubmitMulti"); |
| exchange.getIn().setHeader(SmppConstants.ID, "1"); |
| exchange.getIn().setHeader(SmppConstants.SOURCE_ADDR_TON, TypeOfNumber.NATIONAL.value()); |
| exchange.getIn().setHeader(SmppConstants.SOURCE_ADDR_NPI, NumberingPlanIndicator.NATIONAL.value()); |
| exchange.getIn().setHeader(SmppConstants.SOURCE_ADDR, "1818"); |
| exchange.getIn().setHeader(SmppConstants.DEST_ADDR_TON, TypeOfNumber.INTERNATIONAL.value()); |
| exchange.getIn().setHeader(SmppConstants.DEST_ADDR_NPI, NumberingPlanIndicator.INTERNET.value()); |
| exchange.getIn().setHeader(SmppConstants.DEST_ADDR, Arrays.asList("1919")); |
| exchange.getIn().setHeader(SmppConstants.SCHEDULE_DELIVERY_TIME, new Date(1111111)); |
| exchange.getIn().setHeader(SmppConstants.VALIDITY_PERIOD, new Date(2222222)); |
| exchange.getIn().setHeader(SmppConstants.PROTOCOL_ID, (byte) 1); |
| exchange.getIn().setHeader(SmppConstants.PRIORITY_FLAG, (byte) 2); |
| exchange.getIn().setHeader(SmppConstants.REGISTERED_DELIVERY, new RegisteredDelivery(SMSCDeliveryReceipt.FAILURE).value()); |
| exchange.getIn().setHeader(SmppConstants.REPLACE_IF_PRESENT_FLAG, ReplaceIfPresentFlag.REPLACE.value()); |
| exchange.getIn().setBody("short message body"); |
| when(session.submitMultiple(eq("CMT"), eq(TypeOfNumber.NATIONAL), eq(NumberingPlanIndicator.NATIONAL), eq("1818"), |
| eq(new Address[]{new Address(TypeOfNumber.INTERNATIONAL, NumberingPlanIndicator.INTERNET, "1919")}), |
| eq(new ESMClass()), eq((byte) 1), eq((byte) 2), eq("-300101001831100+"), eq("-300101003702200+"), eq(new RegisteredDelivery(SMSCDeliveryReceipt.FAILURE)), |
| eq(ReplaceIfPresentFlag.REPLACE), eq(DataCodings.newInstance((byte) 0)), eq((byte) 0), eq("short message body".getBytes()))) |
| .thenReturn(new SubmitMultiResult("1")); |
| |
| command.execute(exchange); |
| |
| assertEquals(Arrays.asList("1"), exchange.getOut().getHeader(SmppConstants.ID)); |
| assertEquals(1, exchange.getOut().getHeader(SmppConstants.SENT_MESSAGE_COUNT)); |
| assertNull(exchange.getOut().getHeader(SmppConstants.ERROR)); |
| } |
| |
| @Test |
| public void executeWithValidityPeriodAsString() throws Exception { |
| Exchange exchange = new DefaultExchange(new DefaultCamelContext(), ExchangePattern.InOut); |
| exchange.getIn().setHeader(SmppConstants.COMMAND, "SubmitMulti"); |
| exchange.getIn().setHeader(SmppConstants.ID, "1"); |
| exchange.getIn().setHeader(SmppConstants.SOURCE_ADDR_TON, TypeOfNumber.NATIONAL.value()); |
| exchange.getIn().setHeader(SmppConstants.SOURCE_ADDR_NPI, NumberingPlanIndicator.NATIONAL.value()); |
| exchange.getIn().setHeader(SmppConstants.SOURCE_ADDR, "1818"); |
| exchange.getIn().setHeader(SmppConstants.DEST_ADDR_TON, TypeOfNumber.INTERNATIONAL.value()); |
| exchange.getIn().setHeader(SmppConstants.DEST_ADDR_NPI, NumberingPlanIndicator.INTERNET.value()); |
| exchange.getIn().setHeader(SmppConstants.DEST_ADDR, Arrays.asList("1919")); |
| exchange.getIn().setHeader(SmppConstants.SCHEDULE_DELIVERY_TIME, new Date(1111111)); |
| exchange.getIn().setHeader(SmppConstants.VALIDITY_PERIOD, "000003000000000R"); // three days |
| exchange.getIn().setHeader(SmppConstants.PROTOCOL_ID, (byte) 1); |
| exchange.getIn().setHeader(SmppConstants.PRIORITY_FLAG, (byte) 2); |
| exchange.getIn().setHeader(SmppConstants.REGISTERED_DELIVERY, new RegisteredDelivery(SMSCDeliveryReceipt.FAILURE).value()); |
| exchange.getIn().setHeader(SmppConstants.REPLACE_IF_PRESENT_FLAG, ReplaceIfPresentFlag.REPLACE.value()); |
| exchange.getIn().setBody("short message body"); |
| when(session.submitMultiple(eq("CMT"), eq(TypeOfNumber.NATIONAL), eq(NumberingPlanIndicator.NATIONAL), eq("1818"), |
| eq(new Address[]{new Address(TypeOfNumber.INTERNATIONAL, NumberingPlanIndicator.INTERNET, "1919")}), |
| eq(new ESMClass()), eq((byte) 1), eq((byte) 2), eq("-300101001831100+"), eq("000003000000000R"), eq(new RegisteredDelivery(SMSCDeliveryReceipt.FAILURE)), |
| eq(ReplaceIfPresentFlag.REPLACE), eq(DataCodings.newInstance((byte) 0)), eq((byte) 0), eq("short message body".getBytes()))) |
| .thenReturn(new SubmitMultiResult("1")); |
| |
| command.execute(exchange); |
| |
| assertEquals(Arrays.asList("1"), exchange.getOut().getHeader(SmppConstants.ID)); |
| assertEquals(1, exchange.getOut().getHeader(SmppConstants.SENT_MESSAGE_COUNT)); |
| assertNull(exchange.getOut().getHeader(SmppConstants.ERROR)); |
| } |
| |
| @Test |
| public void bodyWithSmscDefaultDataCodingNarrowedToCharset() throws Exception { |
| final byte dataCoding = (byte)0x00; /* SMSC-default */ |
| byte[] body = {(byte)0xFF, 'A', 'B', (byte)0x00, (byte)0xFF, (byte)0x7F, 'C', (byte)0xFF}; |
| byte[] bodyNarrowed = {'?', 'A', 'B', '\0', '?', (byte)0x7F, 'C', '?'}; |
| |
| Exchange exchange = new DefaultExchange(new DefaultCamelContext(), ExchangePattern.InOut); |
| exchange.getIn().setHeader(SmppConstants.COMMAND, "SubmitMulti"); |
| exchange.getIn().setHeader(SmppConstants.DATA_CODING, dataCoding); |
| exchange.getIn().setBody(body); |
| Address[] destAddrs = new Address[] { |
| new Address(TypeOfNumber.UNKNOWN, |
| NumberingPlanIndicator.UNKNOWN, |
| "1717") |
| }; |
| |
| when(session.submitMultiple(eq("CMT"), |
| eq(TypeOfNumber.UNKNOWN), |
| eq(NumberingPlanIndicator.UNKNOWN), |
| eq("1616"), |
| eq(destAddrs), |
| eq(new ESMClass()), |
| eq((byte) 0), |
| eq((byte) 1), |
| (String) isNull(), |
| (String) isNull(), |
| eq(new RegisteredDelivery(SMSCDeliveryReceipt.SUCCESS_FAILURE)), |
| eq(ReplaceIfPresentFlag.DEFAULT), |
| eq(DataCodings.newInstance(dataCoding)), |
| eq((byte) 0), |
| eq(bodyNarrowed))) |
| .thenReturn(new SubmitMultiResult("1")); |
| |
| command.execute(exchange); |
| |
| assertEquals(Arrays.asList("1"), exchange.getOut().getHeader(SmppConstants.ID)); |
| } |
| |
| @Test |
| public void bodyWithLatin1DataCodingNarrowedToCharset() throws Exception { |
| final byte dataCoding = (byte)0x03; /* ISO-8859-1 (Latin1) */ |
| byte[] body = {(byte)0xFF, 'A', 'B', (byte)0x00, (byte)0xFF, (byte)0x7F, 'C', (byte)0xFF}; |
| byte[] bodyNarrowed = {'?', 'A', 'B', '\0', '?', (byte)0x7F, 'C', '?'}; |
| |
| Exchange exchange = new DefaultExchange(new DefaultCamelContext(), ExchangePattern.InOut); |
| exchange.getIn().setHeader(SmppConstants.COMMAND, "SubmitMulti"); |
| exchange.getIn().setHeader(SmppConstants.DATA_CODING, dataCoding); |
| exchange.getIn().setBody(body); |
| Address[] destAddrs = new Address[] { |
| new Address(TypeOfNumber.UNKNOWN, |
| NumberingPlanIndicator.UNKNOWN, |
| "1717") |
| }; |
| |
| when(session.submitMultiple(eq("CMT"), |
| eq(TypeOfNumber.UNKNOWN), |
| eq(NumberingPlanIndicator.UNKNOWN), |
| eq("1616"), |
| eq(destAddrs), |
| eq(new ESMClass()), |
| eq((byte) 0), |
| eq((byte) 1), |
| (String) isNull(), |
| (String) isNull(), |
| eq(new RegisteredDelivery(SMSCDeliveryReceipt.SUCCESS_FAILURE)), |
| eq(ReplaceIfPresentFlag.DEFAULT), |
| eq(DataCodings.newInstance(dataCoding)), |
| eq((byte) 0), |
| eq(bodyNarrowed))) |
| .thenReturn(new SubmitMultiResult("1")); |
| |
| command.execute(exchange); |
| |
| assertEquals(Arrays.asList("1"), exchange.getOut().getHeader(SmppConstants.ID)); |
| } |
| |
| @Test |
| public void bodyWithSMPP8bitDataCodingNotModified() throws Exception { |
| final byte dataCoding = (byte)0x04; /* SMPP 8-bit */ |
| byte[] body = {(byte)0xFF, 'A', 'B', (byte)0x00, (byte)0xFF, (byte)0x7F, 'C', (byte)0xFF}; |
| |
| Exchange exchange = new DefaultExchange(new DefaultCamelContext(), ExchangePattern.InOut); |
| exchange.getIn().setHeader(SmppConstants.COMMAND, "SubmitMulti"); |
| exchange.getIn().setHeader(SmppConstants.DATA_CODING, dataCoding); |
| exchange.getIn().setBody(body); |
| Address[] destAddrs = new Address[] { |
| new Address(TypeOfNumber.UNKNOWN, |
| NumberingPlanIndicator.UNKNOWN, |
| "1717") |
| }; |
| |
| when(session.submitMultiple(eq("CMT"), |
| eq(TypeOfNumber.UNKNOWN), |
| eq(NumberingPlanIndicator.UNKNOWN), |
| eq("1616"), |
| eq(destAddrs), |
| eq(new ESMClass()), |
| eq((byte) 0), |
| eq((byte) 1), |
| (String) isNull(), |
| (String) isNull(), |
| eq(new RegisteredDelivery(SMSCDeliveryReceipt.SUCCESS_FAILURE)), |
| eq(ReplaceIfPresentFlag.DEFAULT), |
| eq(DataCodings.newInstance(dataCoding)), |
| eq((byte) 0), |
| eq(body))) |
| .thenReturn(new SubmitMultiResult("1")); |
| |
| command.execute(exchange); |
| |
| assertEquals(Arrays.asList("1"), exchange.getOut().getHeader(SmppConstants.ID)); |
| } |
| |
| @Test |
| public void bodyWithGSM8bitDataCodingNotModified() throws Exception { |
| final byte dataCoding = (byte)0xF7; /* GSM 8-bit class 3 */ |
| byte[] body = {(byte)0xFF, 'A', 'B', (byte)0x00, (byte)0xFF, (byte)0x7F, 'C', (byte)0xFF}; |
| |
| Exchange exchange = new DefaultExchange(new DefaultCamelContext(), ExchangePattern.InOut); |
| exchange.getIn().setHeader(SmppConstants.COMMAND, "SubmitMulti"); |
| exchange.getIn().setHeader(SmppConstants.DATA_CODING, dataCoding); |
| exchange.getIn().setBody(body); |
| Address[] destAddrs = new Address[] { |
| new Address(TypeOfNumber.UNKNOWN, |
| NumberingPlanIndicator.UNKNOWN, |
| "1717") |
| }; |
| |
| when(session.submitMultiple(eq("CMT"), |
| eq(TypeOfNumber.UNKNOWN), |
| eq(NumberingPlanIndicator.UNKNOWN), |
| eq("1616"), |
| eq(destAddrs), |
| eq(new ESMClass()), |
| eq((byte) 0), |
| eq((byte) 1), |
| (String) isNull(), |
| (String) isNull(), |
| eq(new RegisteredDelivery(SMSCDeliveryReceipt.SUCCESS_FAILURE)), |
| eq(ReplaceIfPresentFlag.DEFAULT), |
| eq(DataCodings.newInstance(dataCoding)), |
| eq((byte) 0), |
| eq(body))) |
| .thenReturn(new SubmitMultiResult("1")); |
| |
| command.execute(exchange); |
| |
| assertEquals(Arrays.asList("1"), exchange.getOut().getHeader(SmppConstants.ID)); |
| } |
| |
| @Test |
| public void eightBitDataCodingOverridesDefaultAlphabet() throws Exception { |
| final byte binDataCoding = (byte)0x04; /* SMPP 8-bit */ |
| byte[] body = {(byte)0xFF, 'A', 'B', (byte)0x00, (byte)0xFF, (byte)0x7F, 'C', (byte)0xFF}; |
| |
| Exchange exchange = new DefaultExchange(new DefaultCamelContext(), ExchangePattern.InOut); |
| exchange.getIn().setHeader(SmppConstants.COMMAND, "SubmitMulti"); |
| exchange.getIn().setHeader(SmppConstants.ALPHABET, Alphabet.ALPHA_DEFAULT.value()); |
| exchange.getIn().setHeader(SmppConstants.DATA_CODING, binDataCoding); |
| exchange.getIn().setBody(body); |
| Address[] destAddrs = new Address[] { |
| new Address(TypeOfNumber.UNKNOWN, |
| NumberingPlanIndicator.UNKNOWN, |
| "1717") |
| }; |
| |
| when(session.submitMultiple(eq("CMT"), |
| eq(TypeOfNumber.UNKNOWN), |
| eq(NumberingPlanIndicator.UNKNOWN), |
| eq("1616"), |
| eq(destAddrs), |
| eq(new ESMClass()), |
| eq((byte) 0), |
| eq((byte) 1), |
| (String) isNull(), |
| (String) isNull(), |
| eq(new RegisteredDelivery(SMSCDeliveryReceipt.SUCCESS_FAILURE)), |
| eq(ReplaceIfPresentFlag.DEFAULT), |
| eq(DataCodings.newInstance(binDataCoding)), |
| eq((byte) 0), |
| eq(body))) |
| .thenReturn(new SubmitMultiResult("1")); |
| |
| command.execute(exchange); |
| |
| assertEquals(Arrays.asList("1"), exchange.getOut().getHeader(SmppConstants.ID)); |
| } |
| |
| @Test |
| public void latin1DataCodingOverridesEightBitAlphabet() throws Exception { |
| final byte latin1DataCoding = (byte)0x03; /* ISO-8859-1 (Latin1) */ |
| byte[] body = {(byte)0xFF, 'A', 'B', (byte)0x00, (byte)0xFF, (byte)0x7F, 'C', (byte)0xFF}; |
| byte[] bodyNarrowed = {'?', 'A', 'B', '\0', '?', (byte)0x7F, 'C', '?'}; |
| |
| Exchange exchange = new DefaultExchange(new DefaultCamelContext(), ExchangePattern.InOut); |
| exchange.getIn().setHeader(SmppConstants.COMMAND, "SubmitMulti"); |
| exchange.getIn().setHeader(SmppConstants.ALPHABET, Alphabet.ALPHA_8_BIT.value()); |
| exchange.getIn().setHeader(SmppConstants.DATA_CODING, latin1DataCoding); |
| exchange.getIn().setBody(body); |
| Address[] destAddrs = new Address[] { |
| new Address(TypeOfNumber.UNKNOWN, |
| NumberingPlanIndicator.UNKNOWN, |
| "1717") |
| }; |
| |
| when(session.submitMultiple(eq("CMT"), |
| eq(TypeOfNumber.UNKNOWN), |
| eq(NumberingPlanIndicator.UNKNOWN), |
| eq("1616"), |
| eq(destAddrs), |
| eq(new ESMClass()), |
| eq((byte) 0), |
| eq((byte) 1), |
| (String) isNull(), |
| (String) isNull(), |
| eq(new RegisteredDelivery(SMSCDeliveryReceipt.SUCCESS_FAILURE)), |
| eq(ReplaceIfPresentFlag.DEFAULT), |
| eq(DataCodings.newInstance(latin1DataCoding)), |
| eq((byte) 0), |
| eq(bodyNarrowed))) |
| .thenReturn(new SubmitMultiResult("1")); |
| |
| command.execute(exchange); |
| |
| assertEquals(Arrays.asList("1"), exchange.getOut().getHeader(SmppConstants.ID)); |
| } |
| |
| @Test |
| public void executeWithOptionalParameter() throws Exception { |
| Exchange exchange = new DefaultExchange(new DefaultCamelContext(), ExchangePattern.InOut); |
| exchange.getIn().setHeader(SmppConstants.COMMAND, "SubmitMulti"); |
| exchange.getIn().setHeader(SmppConstants.ID, "1"); |
| exchange.getIn().setHeader(SmppConstants.SOURCE_ADDR_TON, TypeOfNumber.NATIONAL.value()); |
| exchange.getIn().setHeader(SmppConstants.SOURCE_ADDR_NPI, NumberingPlanIndicator.NATIONAL.value()); |
| exchange.getIn().setHeader(SmppConstants.SOURCE_ADDR, "1818"); |
| exchange.getIn().setHeader(SmppConstants.DEST_ADDR_TON, TypeOfNumber.INTERNATIONAL.value()); |
| exchange.getIn().setHeader(SmppConstants.DEST_ADDR_NPI, NumberingPlanIndicator.INTERNET.value()); |
| exchange.getIn().setHeader(SmppConstants.DEST_ADDR, Arrays.asList("1919")); |
| exchange.getIn().setHeader(SmppConstants.SCHEDULE_DELIVERY_TIME, new Date(1111111)); |
| exchange.getIn().setHeader(SmppConstants.VALIDITY_PERIOD, new Date(2222222)); |
| exchange.getIn().setHeader(SmppConstants.PROTOCOL_ID, (byte) 1); |
| exchange.getIn().setHeader(SmppConstants.PRIORITY_FLAG, (byte) 2); |
| exchange.getIn().setHeader(SmppConstants.REGISTERED_DELIVERY, new RegisteredDelivery(SMSCDeliveryReceipt.FAILURE).value()); |
| exchange.getIn().setHeader(SmppConstants.REPLACE_IF_PRESENT_FLAG, ReplaceIfPresentFlag.REPLACE.value()); |
| Map<String, String> optionalParameters = new LinkedHashMap<>(); |
| optionalParameters.put("SOURCE_SUBADDRESS", "1292"); |
| optionalParameters.put("ADDITIONAL_STATUS_INFO_TEXT", "urgent"); |
| optionalParameters.put("DEST_ADDR_SUBUNIT", "4"); |
| optionalParameters.put("DEST_TELEMATICS_ID", "2"); |
| optionalParameters.put("QOS_TIME_TO_LIVE", "3600000"); |
| optionalParameters.put("ALERT_ON_MESSAGE_DELIVERY", null); |
| exchange.getIn().setHeader(SmppConstants.OPTIONAL_PARAMETERS, optionalParameters); |
| exchange.getIn().setBody("short message body"); |
| when(session.submitMultiple(eq("CMT"), eq(TypeOfNumber.NATIONAL), eq(NumberingPlanIndicator.NATIONAL), eq("1818"), |
| eq(new Address[]{new Address(TypeOfNumber.INTERNATIONAL, NumberingPlanIndicator.INTERNET, "1919")}), |
| eq(new ESMClass()), eq((byte) 1), eq((byte) 2), eq("-300101001831100+"), eq("-300101003702200+"), eq(new RegisteredDelivery(SMSCDeliveryReceipt.FAILURE)), |
| eq(ReplaceIfPresentFlag.REPLACE), eq(DataCodings.newInstance((byte) 0)), eq((byte) 0), eq("short message body".getBytes()), |
| eq(new OptionalParameter.Source_subaddress("1292".getBytes())), |
| eq(new OptionalParameter.Additional_status_info_text("urgent".getBytes())), |
| eq(new OptionalParameter.Dest_addr_subunit((byte) 4)), |
| eq(new OptionalParameter.Dest_telematics_id((short) 2)), |
| eq(new OptionalParameter.Qos_time_to_live(3600000)), |
| eq(new OptionalParameter.Alert_on_message_delivery("O".getBytes())))) |
| .thenReturn(new SubmitMultiResult("1")); |
| |
| command.execute(exchange); |
| |
| assertEquals(Arrays.asList("1"), exchange.getOut().getHeader(SmppConstants.ID)); |
| assertEquals(1, exchange.getOut().getHeader(SmppConstants.SENT_MESSAGE_COUNT)); |
| assertNull(exchange.getOut().getHeader(SmppConstants.ERROR)); |
| } |
| |
| @Test |
| public void executeWithOptionalParameterNewStyle() throws Exception { |
| Exchange exchange = new DefaultExchange(new DefaultCamelContext(), ExchangePattern.InOut); |
| exchange.getIn().setHeader(SmppConstants.COMMAND, "SubmitMulti"); |
| exchange.getIn().setHeader(SmppConstants.ID, "1"); |
| exchange.getIn().setHeader(SmppConstants.SOURCE_ADDR_TON, TypeOfNumber.NATIONAL.value()); |
| exchange.getIn().setHeader(SmppConstants.SOURCE_ADDR_NPI, NumberingPlanIndicator.NATIONAL.value()); |
| exchange.getIn().setHeader(SmppConstants.SOURCE_ADDR, "1818"); |
| exchange.getIn().setHeader(SmppConstants.DEST_ADDR_TON, TypeOfNumber.INTERNATIONAL.value()); |
| exchange.getIn().setHeader(SmppConstants.DEST_ADDR_NPI, NumberingPlanIndicator.INTERNET.value()); |
| exchange.getIn().setHeader(SmppConstants.DEST_ADDR, Arrays.asList("1919")); |
| exchange.getIn().setHeader(SmppConstants.SCHEDULE_DELIVERY_TIME, new Date(1111111)); |
| exchange.getIn().setHeader(SmppConstants.VALIDITY_PERIOD, new Date(2222222)); |
| exchange.getIn().setHeader(SmppConstants.PROTOCOL_ID, (byte) 1); |
| exchange.getIn().setHeader(SmppConstants.PRIORITY_FLAG, (byte) 2); |
| exchange.getIn().setHeader(SmppConstants.REGISTERED_DELIVERY, new RegisteredDelivery(SMSCDeliveryReceipt.FAILURE).value()); |
| exchange.getIn().setHeader(SmppConstants.REPLACE_IF_PRESENT_FLAG, ReplaceIfPresentFlag.REPLACE.value()); |
| Map<Short, Object> optionalParameters = new LinkedHashMap<>(); |
| // standard optional parameter |
| optionalParameters.put(Short.valueOf((short) 0x0202), "1292".getBytes("UTF-8")); |
| optionalParameters.put(Short.valueOf((short) 0x001D), "urgent"); |
| optionalParameters.put(Short.valueOf((short) 0x0005), Byte.valueOf("4")); |
| optionalParameters.put(Short.valueOf((short) 0x0008), Short.valueOf((short) 2)); |
| optionalParameters.put(Short.valueOf((short) 0x0017), Integer.valueOf(3600000)); |
| optionalParameters.put(Short.valueOf((short) 0x130C), null); |
| // vendor specific optional parameter |
| optionalParameters.put(Short.valueOf((short) 0x2150), "0815".getBytes("UTF-8")); |
| optionalParameters.put(Short.valueOf((short) 0x2151), "0816"); |
| optionalParameters.put(Short.valueOf((short) 0x2152), Byte.valueOf("6")); |
| optionalParameters.put(Short.valueOf((short) 0x2153), Short.valueOf((short) 9)); |
| optionalParameters.put(Short.valueOf((short) 0x2154), Integer.valueOf(7400000)); |
| optionalParameters.put(Short.valueOf((short) 0x2155), null); |
| exchange.getIn().setHeader(SmppConstants.OPTIONAL_PARAMETER, optionalParameters); |
| exchange.getIn().setBody("short message body"); |
| when(session.submitMultiple(eq("CMT"), eq(TypeOfNumber.NATIONAL), eq(NumberingPlanIndicator.NATIONAL), eq("1818"), |
| eq(new Address[]{new Address(TypeOfNumber.INTERNATIONAL, NumberingPlanIndicator.INTERNET, "1919")}), |
| eq(new ESMClass()), eq((byte) 1), eq((byte) 2), eq("-300101001831100+"), eq("-300101003702200+"), eq(new RegisteredDelivery(SMSCDeliveryReceipt.FAILURE)), |
| eq(ReplaceIfPresentFlag.REPLACE), eq(DataCodings.newInstance((byte) 0)), eq((byte) 0), eq("short message body".getBytes()), |
| eq(new OptionalParameter.OctetString(Tag.SOURCE_SUBADDRESS, "1292")), |
| eq(new OptionalParameter.COctetString(Tag.ADDITIONAL_STATUS_INFO_TEXT.code(), "urgent")), |
| eq(new OptionalParameter.Byte(Tag.DEST_ADDR_SUBUNIT, (byte) 4)), |
| eq(new OptionalParameter.Short(Tag.DEST_TELEMATICS_ID.code(), (short) 2)), |
| eq(new OptionalParameter.Int(Tag.QOS_TIME_TO_LIVE, 3600000)), |
| eq(new OptionalParameter.Null(Tag.ALERT_ON_MESSAGE_DELIVERY)), |
| eq(new OptionalParameter.OctetString((short) 0x2150, "1292", "UTF-8")), |
| eq(new OptionalParameter.COctetString((short) 0x2151, "0816")), |
| eq(new OptionalParameter.Byte((short) 0x2152, (byte) 6)), |
| eq(new OptionalParameter.Short((short) 0x2153, (short) 9)), |
| eq(new OptionalParameter.Int((short) 0x2154, 7400000)), |
| eq(new OptionalParameter.Null((short) 0x2155)))) |
| .thenReturn(new SubmitMultiResult("1")); |
| |
| command.execute(exchange); |
| |
| assertEquals(Arrays.asList("1"), exchange.getOut().getHeader(SmppConstants.ID)); |
| assertEquals(1, exchange.getOut().getHeader(SmppConstants.SENT_MESSAGE_COUNT)); |
| assertNull(exchange.getOut().getHeader(SmppConstants.ERROR)); |
| } |
| } |
