This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
The following commit(s) were added to refs/heads/main by this push:
new 644dd9c [create-pull-request] automated change
644dd9c is described below
commit 644dd9c7605d43560d36496c0145ab1a95ca717b
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Sat Jun 12 03:21:30 2021 +0000
[create-pull-request] automated change
---
.../resources/connectors/camel-pubnub-sink.json | 64 ++++++++++++++++++++++
.../resources/connectors/camel-pubnub-source.json | 56 +++++++++++++++++++
.../resources/connectors/camel-smpp-sink.json | 14 +++++
.../resources/connectors/camel-smpp-source.json | 14 +++++
.../resources/connectors/camel-smpps-sink.json | 14 +++++
.../resources/connectors/camel-smpps-source.json | 14 +++++
.../src/generated/resources/camel-pubnub-sink.json | 64 ++++++++++++++++++++++
.../generated/resources/camel-pubnub-source.json | 56 +++++++++++++++++++
.../docs/camel-pubnub-kafka-sink-connector.adoc | 11 +++-
.../docs/camel-pubnub-kafka-source-connector.adoc | 11 +++-
.../pubnub/CamelPubnubSinkConnectorConfig.java | 36 ++++++++++++
.../pubnub/CamelPubnubSourceConnectorConfig.java | 36 ++++++++++++
.../src/generated/resources/camel-smpp-sink.json | 14 +++++
.../src/generated/resources/camel-smpp-source.json | 14 +++++
.../main/docs/camel-smpp-kafka-sink-connector.adoc | 4 +-
.../docs/camel-smpp-kafka-source-connector.adoc | 4 +-
.../smpp/CamelSmppSinkConnectorConfig.java | 8 +++
.../smpp/CamelSmppSourceConnectorConfig.java | 8 +++
.../src/generated/resources/camel-smpps-sink.json | 14 +++++
.../generated/resources/camel-smpps-source.json | 14 +++++
.../docs/camel-smpps-kafka-sink-connector.adoc | 4 +-
.../docs/camel-smpps-kafka-source-connector.adoc | 4 +-
.../smpps/CamelSmppsSinkConnectorConfig.java | 8 +++
.../smpps/CamelSmppsSourceConnectorConfig.java | 8 +++
.../camel-pubnub-kafka-sink-connector.adoc | 15 +++--
.../camel-pubnub-kafka-source-connector.adoc | 15 +++--
.../camel-smpp-kafka-sink-connector.adoc | 8 +--
.../camel-smpp-kafka-source-connector.adoc | 8 +--
.../camel-smpps-kafka-sink-connector.adoc | 8 +--
.../camel-smpps-kafka-source-connector.adoc | 8 +--
30 files changed, 520 insertions(+), 36 deletions(-)
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-pubnub-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-pubnub-sink.json
index b5345b6..a348427 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-pubnub-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-pubnub-sink.json
@@ -86,6 +86,18 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.pubnub.configuration": {
+ "name": "camel.component.pubnub.configuration",
+ "description": "The component configurations",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.component.pubnub.uuid": {
+ "name": "camel.component.pubnub.uuid",
+ "description": "UUID to be used as a device identifier,
a default UUID is generated if not passed.",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.pubnub.lazyStartProducer": {
"name": "camel.component.pubnub.lazyStartProducer",
"description": "Whether the producer should be started
lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a producer may otherwise
fail during starting and cause the route to fail being started. By deferring
this startup to be lazy then the startup failure can be handled during routing
messages via Camel's routing error handlers. Beware that when the first message
is processed then creating and starting the pr [...]
@@ -93,12 +105,64 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.pubnub.operation": {
+ "name": "camel.component.pubnub.operation",
+ "description": "The operation to perform. PUBLISH:
Default. Send a message to all subscribers of a channel. FIRE: allows the
client to send a message to BLOCKS Event Handlers. These messages will go
directly to any Event Handlers registered on the channel. HERENOW: Obtain
information about the current state of a channel including a list of unique
user-ids currently subscribed to the channel and the total occupancy count.
WHERENOW: Obtain information about the current list of channels [...]
+ "priority": "MEDIUM",
+ "required": "false",
+ "enum": [
+ "HERENOW",
+ "WHERENOW",
+ "GETSTATE",
+ "SETSTATE",
+ "GETHISTORY",
+ "PUBLISH",
+ "FIRE"
+ ]
+ },
"camel.component.pubnub.autowiredEnabled": {
"name": "camel.component.pubnub.autowiredEnabled",
"description": "Whether autowiring is enabled. This is
used for automatic autowiring options (the option must be marked as autowired)
by looking up in the registry to find if there is a single instance of matching
type, which then gets configured on the component. This can be used for
automatic configuring JDBC data sources, JMS connection factories, AWS Clients,
etc.",
"defaultValue": "true",
"priority": "MEDIUM",
"required": "false"
+ },
+ "camel.component.pubnub.authKey": {
+ "name": "camel.component.pubnub.authKey",
+ "description": "If Access Manager is utilized, client
will use this authKey in all restricted requests.",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.component.pubnub.cipherKey": {
+ "name": "camel.component.pubnub.cipherKey",
+ "description": "If cipher is passed, all communications
to\/from PubNub will be encrypted.",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.component.pubnub.publishKey": {
+ "name": "camel.component.pubnub.publishKey",
+ "description": "The publish key obtained from your
PubNub account. Required when publishing messages.",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.component.pubnub.secretKey": {
+ "name": "camel.component.pubnub.secretKey",
+ "description": "The secret key used for message
signing.",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.component.pubnub.secure": {
+ "name": "camel.component.pubnub.secure",
+ "description": "Use SSL for secure transmission.",
+ "defaultValue": "true",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.component.pubnub.subscribeKey": {
+ "name": "camel.component.pubnub.subscribeKey",
+ "description": "The subscribe key obtained from your
PubNub account. Required when subscribing to channels or listening for presence
events",
+ "priority": "MEDIUM",
+ "required": "false"
}
}
}
\ No newline at end of file
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-pubnub-source.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-pubnub-source.json
index 37f9d32..1a4e4a7 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-pubnub-source.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-pubnub-source.json
@@ -95,6 +95,18 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.pubnub.configuration": {
+ "name": "camel.component.pubnub.configuration",
+ "description": "The component configurations",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.component.pubnub.uuid": {
+ "name": "camel.component.pubnub.uuid",
+ "description": "UUID to be used as a device identifier,
a default UUID is generated if not passed.",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.pubnub.bridgeErrorHandler": {
"name": "camel.component.pubnub.bridgeErrorHandler",
"description": "Allows for bridging the consumer to the
Camel routing Error Handler, which mean any exceptions occurred while the
consumer is trying to pickup incoming messages, or the likes, will now be
processed as a message and handled by the routing Error Handler. By default the
consumer will use the org.apache.camel.spi.ExceptionHandler to deal with
exceptions, that will be logged at WARN or ERROR level and ignored.",
@@ -102,12 +114,56 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.pubnub.withPresence": {
+ "name": "camel.component.pubnub.withPresence",
+ "description": "Also subscribe to related presence
information",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.pubnub.autowiredEnabled": {
"name": "camel.component.pubnub.autowiredEnabled",
"description": "Whether autowiring is enabled. This is
used for automatic autowiring options (the option must be marked as autowired)
by looking up in the registry to find if there is a single instance of matching
type, which then gets configured on the component. This can be used for
automatic configuring JDBC data sources, JMS connection factories, AWS Clients,
etc.",
"defaultValue": "true",
"priority": "MEDIUM",
"required": "false"
+ },
+ "camel.component.pubnub.authKey": {
+ "name": "camel.component.pubnub.authKey",
+ "description": "If Access Manager is utilized, client
will use this authKey in all restricted requests.",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.component.pubnub.cipherKey": {
+ "name": "camel.component.pubnub.cipherKey",
+ "description": "If cipher is passed, all communications
to\/from PubNub will be encrypted.",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.component.pubnub.publishKey": {
+ "name": "camel.component.pubnub.publishKey",
+ "description": "The publish key obtained from your
PubNub account. Required when publishing messages.",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.component.pubnub.secretKey": {
+ "name": "camel.component.pubnub.secretKey",
+ "description": "The secret key used for message
signing.",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.component.pubnub.secure": {
+ "name": "camel.component.pubnub.secure",
+ "description": "Use SSL for secure transmission.",
+ "defaultValue": "true",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.component.pubnub.subscribeKey": {
+ "name": "camel.component.pubnub.subscribeKey",
+ "description": "The subscribe key obtained from your
PubNub account. Required when subscribing to channels or listening for presence
events",
+ "priority": "MEDIUM",
+ "required": "false"
}
}
}
\ No newline at end of file
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-smpp-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-smpp-sink.json
index 2ac1d32..cbcaa0d 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-smpp-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-smpp-sink.json
@@ -269,6 +269,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.sink.endpoint.singleDLR": {
+ "name": "camel.sink.endpoint.singleDLR",
+ "description": "When true, the SMSC delivery receipt
would be requested only for the last segment of a multi-segment (long) message.
For short messages, with only 1 segment the behaviour is unchanged.",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.transactionTimer": {
"name": "camel.sink.endpoint.transactionTimer",
"description": "Defines the maximum period of
inactivity allowed after a transaction, after which an SMPP entity may assume
that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME).",
@@ -610,6 +617,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.smpp.singleDLR": {
+ "name": "camel.component.smpp.singleDLR",
+ "description": "When true, the SMSC delivery receipt
would be requested only for the last segment of a multi-segment (long) message.
For short messages, with only 1 segment the behaviour is unchanged.",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.smpp.transactionTimer": {
"name": "camel.component.smpp.transactionTimer",
"description": "Defines the maximum period of
inactivity allowed after a transaction, after which an SMPP entity may assume
that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME).",
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-smpp-source.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-smpp-source.json
index 61f5679..c9775e6 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-smpp-source.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-smpp-source.json
@@ -119,6 +119,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.source.endpoint.singleDLR": {
+ "name": "camel.source.endpoint.singleDLR",
+ "description": "When true, the SMSC delivery receipt
would be requested only for the last segment of a multi-segment (long) message.
For short messages, with only 1 segment the behaviour is unchanged.",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.source.endpoint.transactionTimer": {
"name": "camel.source.endpoint.transactionTimer",
"description": "Defines the maximum period of
inactivity allowed after a transaction, after which an SMPP entity may assume
that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME).",
@@ -293,6 +300,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.smpp.singleDLR": {
+ "name": "camel.component.smpp.singleDLR",
+ "description": "When true, the SMSC delivery receipt
would be requested only for the last segment of a multi-segment (long) message.
For short messages, with only 1 segment the behaviour is unchanged.",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.smpp.transactionTimer": {
"name": "camel.component.smpp.transactionTimer",
"description": "Defines the maximum period of
inactivity allowed after a transaction, after which an SMPP entity may assume
that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME).",
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-smpps-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-smpps-sink.json
index abbf4a4..22adb09 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-smpps-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-smpps-sink.json
@@ -269,6 +269,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.sink.endpoint.singleDLR": {
+ "name": "camel.sink.endpoint.singleDLR",
+ "description": "When true, the SMSC delivery receipt
would be requested only for the last segment of a multi-segment (long) message.
For short messages, with only 1 segment the behaviour is unchanged.",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.transactionTimer": {
"name": "camel.sink.endpoint.transactionTimer",
"description": "Defines the maximum period of
inactivity allowed after a transaction, after which an SMPP entity may assume
that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME).",
@@ -610,6 +617,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.smpps.singleDLR": {
+ "name": "camel.component.smpps.singleDLR",
+ "description": "When true, the SMSC delivery receipt
would be requested only for the last segment of a multi-segment (long) message.
For short messages, with only 1 segment the behaviour is unchanged.",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.smpps.transactionTimer": {
"name": "camel.component.smpps.transactionTimer",
"description": "Defines the maximum period of
inactivity allowed after a transaction, after which an SMPP entity may assume
that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME).",
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-smpps-source.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-smpps-source.json
index f322cc9..c2e23d2 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-smpps-source.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-smpps-source.json
@@ -119,6 +119,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.source.endpoint.singleDLR": {
+ "name": "camel.source.endpoint.singleDLR",
+ "description": "When true, the SMSC delivery receipt
would be requested only for the last segment of a multi-segment (long) message.
For short messages, with only 1 segment the behaviour is unchanged.",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.source.endpoint.transactionTimer": {
"name": "camel.source.endpoint.transactionTimer",
"description": "Defines the maximum period of
inactivity allowed after a transaction, after which an SMPP entity may assume
that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME).",
@@ -293,6 +300,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.smpps.singleDLR": {
+ "name": "camel.component.smpps.singleDLR",
+ "description": "When true, the SMSC delivery receipt
would be requested only for the last segment of a multi-segment (long) message.
For short messages, with only 1 segment the behaviour is unchanged.",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.smpps.transactionTimer": {
"name": "camel.component.smpps.transactionTimer",
"description": "Defines the maximum period of
inactivity allowed after a transaction, after which an SMPP entity may assume
that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME).",
diff --git
a/connectors/camel-pubnub-kafka-connector/src/generated/resources/camel-pubnub-sink.json
b/connectors/camel-pubnub-kafka-connector/src/generated/resources/camel-pubnub-sink.json
index b5345b6..a348427 100644
---
a/connectors/camel-pubnub-kafka-connector/src/generated/resources/camel-pubnub-sink.json
+++
b/connectors/camel-pubnub-kafka-connector/src/generated/resources/camel-pubnub-sink.json
@@ -86,6 +86,18 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.pubnub.configuration": {
+ "name": "camel.component.pubnub.configuration",
+ "description": "The component configurations",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.component.pubnub.uuid": {
+ "name": "camel.component.pubnub.uuid",
+ "description": "UUID to be used as a device identifier,
a default UUID is generated if not passed.",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.pubnub.lazyStartProducer": {
"name": "camel.component.pubnub.lazyStartProducer",
"description": "Whether the producer should be started
lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a producer may otherwise
fail during starting and cause the route to fail being started. By deferring
this startup to be lazy then the startup failure can be handled during routing
messages via Camel's routing error handlers. Beware that when the first message
is processed then creating and starting the pr [...]
@@ -93,12 +105,64 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.pubnub.operation": {
+ "name": "camel.component.pubnub.operation",
+ "description": "The operation to perform. PUBLISH:
Default. Send a message to all subscribers of a channel. FIRE: allows the
client to send a message to BLOCKS Event Handlers. These messages will go
directly to any Event Handlers registered on the channel. HERENOW: Obtain
information about the current state of a channel including a list of unique
user-ids currently subscribed to the channel and the total occupancy count.
WHERENOW: Obtain information about the current list of channels [...]
+ "priority": "MEDIUM",
+ "required": "false",
+ "enum": [
+ "HERENOW",
+ "WHERENOW",
+ "GETSTATE",
+ "SETSTATE",
+ "GETHISTORY",
+ "PUBLISH",
+ "FIRE"
+ ]
+ },
"camel.component.pubnub.autowiredEnabled": {
"name": "camel.component.pubnub.autowiredEnabled",
"description": "Whether autowiring is enabled. This is
used for automatic autowiring options (the option must be marked as autowired)
by looking up in the registry to find if there is a single instance of matching
type, which then gets configured on the component. This can be used for
automatic configuring JDBC data sources, JMS connection factories, AWS Clients,
etc.",
"defaultValue": "true",
"priority": "MEDIUM",
"required": "false"
+ },
+ "camel.component.pubnub.authKey": {
+ "name": "camel.component.pubnub.authKey",
+ "description": "If Access Manager is utilized, client
will use this authKey in all restricted requests.",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.component.pubnub.cipherKey": {
+ "name": "camel.component.pubnub.cipherKey",
+ "description": "If cipher is passed, all communications
to\/from PubNub will be encrypted.",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.component.pubnub.publishKey": {
+ "name": "camel.component.pubnub.publishKey",
+ "description": "The publish key obtained from your
PubNub account. Required when publishing messages.",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.component.pubnub.secretKey": {
+ "name": "camel.component.pubnub.secretKey",
+ "description": "The secret key used for message
signing.",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.component.pubnub.secure": {
+ "name": "camel.component.pubnub.secure",
+ "description": "Use SSL for secure transmission.",
+ "defaultValue": "true",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.component.pubnub.subscribeKey": {
+ "name": "camel.component.pubnub.subscribeKey",
+ "description": "The subscribe key obtained from your
PubNub account. Required when subscribing to channels or listening for presence
events",
+ "priority": "MEDIUM",
+ "required": "false"
}
}
}
\ No newline at end of file
diff --git
a/connectors/camel-pubnub-kafka-connector/src/generated/resources/camel-pubnub-source.json
b/connectors/camel-pubnub-kafka-connector/src/generated/resources/camel-pubnub-source.json
index 37f9d32..1a4e4a7 100644
---
a/connectors/camel-pubnub-kafka-connector/src/generated/resources/camel-pubnub-source.json
+++
b/connectors/camel-pubnub-kafka-connector/src/generated/resources/camel-pubnub-source.json
@@ -95,6 +95,18 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.pubnub.configuration": {
+ "name": "camel.component.pubnub.configuration",
+ "description": "The component configurations",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.component.pubnub.uuid": {
+ "name": "camel.component.pubnub.uuid",
+ "description": "UUID to be used as a device identifier,
a default UUID is generated if not passed.",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.pubnub.bridgeErrorHandler": {
"name": "camel.component.pubnub.bridgeErrorHandler",
"description": "Allows for bridging the consumer to the
Camel routing Error Handler, which mean any exceptions occurred while the
consumer is trying to pickup incoming messages, or the likes, will now be
processed as a message and handled by the routing Error Handler. By default the
consumer will use the org.apache.camel.spi.ExceptionHandler to deal with
exceptions, that will be logged at WARN or ERROR level and ignored.",
@@ -102,12 +114,56 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.pubnub.withPresence": {
+ "name": "camel.component.pubnub.withPresence",
+ "description": "Also subscribe to related presence
information",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.pubnub.autowiredEnabled": {
"name": "camel.component.pubnub.autowiredEnabled",
"description": "Whether autowiring is enabled. This is
used for automatic autowiring options (the option must be marked as autowired)
by looking up in the registry to find if there is a single instance of matching
type, which then gets configured on the component. This can be used for
automatic configuring JDBC data sources, JMS connection factories, AWS Clients,
etc.",
"defaultValue": "true",
"priority": "MEDIUM",
"required": "false"
+ },
+ "camel.component.pubnub.authKey": {
+ "name": "camel.component.pubnub.authKey",
+ "description": "If Access Manager is utilized, client
will use this authKey in all restricted requests.",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.component.pubnub.cipherKey": {
+ "name": "camel.component.pubnub.cipherKey",
+ "description": "If cipher is passed, all communications
to\/from PubNub will be encrypted.",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.component.pubnub.publishKey": {
+ "name": "camel.component.pubnub.publishKey",
+ "description": "The publish key obtained from your
PubNub account. Required when publishing messages.",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.component.pubnub.secretKey": {
+ "name": "camel.component.pubnub.secretKey",
+ "description": "The secret key used for message
signing.",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.component.pubnub.secure": {
+ "name": "camel.component.pubnub.secure",
+ "description": "Use SSL for secure transmission.",
+ "defaultValue": "true",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.component.pubnub.subscribeKey": {
+ "name": "camel.component.pubnub.subscribeKey",
+ "description": "The subscribe key obtained from your
PubNub account. Required when subscribing to channels or listening for presence
events",
+ "priority": "MEDIUM",
+ "required": "false"
}
}
}
\ No newline at end of file
diff --git
a/connectors/camel-pubnub-kafka-connector/src/main/docs/camel-pubnub-kafka-sink-connector.adoc
b/connectors/camel-pubnub-kafka-connector/src/main/docs/camel-pubnub-kafka-sink-connector.adoc
index aff128b..c31a762 100644
---
a/connectors/camel-pubnub-kafka-connector/src/main/docs/camel-pubnub-kafka-sink-connector.adoc
+++
b/connectors/camel-pubnub-kafka-connector/src/main/docs/camel-pubnub-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.pubnub.CamelPubnubSinkConnector
----
-The camel-pubnub sink connector supports 13 options, which are listed below.
+The camel-pubnub sink connector supports 22 options, which are listed below.
@@ -42,8 +42,17 @@ The camel-pubnub sink connector supports 13 options, which
are listed below.
| *camel.sink.endpoint.secretKey* | The secret key used for message signing. |
null | false | MEDIUM
| *camel.sink.endpoint.secure* | Use SSL for secure transmission. | true |
false | MEDIUM
| *camel.sink.endpoint.subscribeKey* | The subscribe key obtained from your
PubNub account. Required when subscribing to channels or listening for presence
events | null | false | MEDIUM
+| *camel.component.pubnub.configuration* | The component configurations | null
| false | MEDIUM
+| *camel.component.pubnub.uuid* | UUID to be used as a device identifier, a
default UUID is generated if not passed. | null | false | MEDIUM
| *camel.component.pubnub.lazyStartProducer* | Whether the producer should be
started lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a producer may otherwise
fail during starting and cause the route to fail being started. By deferring
this startup to be lazy then the startup failure can be handled during routing
messages via Camel's routing error handlers. Beware that when the first message
is processed then [...]
+| *camel.component.pubnub.operation* | The operation to perform. PUBLISH:
Default. Send a message to all subscribers of a channel. FIRE: allows the
client to send a message to BLOCKS Event Handlers. These messages will go
directly to any Event Handlers registered on the channel. HERENOW: Obtain
information about the current state of a channel including a list of unique
user-ids currently subscribed to the channel and the total occupancy count.
WHERENOW: Obtain information about the curre [...]
| *camel.component.pubnub.autowiredEnabled* | Whether autowiring is enabled.
This is used for automatic autowiring options (the option must be marked as
autowired) by looking up in the registry to find if there is a single instance
of matching type, which then gets configured on the component. This can be used
for automatic configuring JDBC data sources, JMS connection factories, AWS
Clients, etc. | true | false | MEDIUM
+| *camel.component.pubnub.authKey* | If Access Manager is utilized, client
will use this authKey in all restricted requests. | null | false | MEDIUM
+| *camel.component.pubnub.cipherKey* | If cipher is passed, all communications
to/from PubNub will be encrypted. | null | false | MEDIUM
+| *camel.component.pubnub.publishKey* | The publish key obtained from your
PubNub account. Required when publishing messages. | null | false | MEDIUM
+| *camel.component.pubnub.secretKey* | The secret key used for message
signing. | null | false | MEDIUM
+| *camel.component.pubnub.secure* | Use SSL for secure transmission. | true |
false | MEDIUM
+| *camel.component.pubnub.subscribeKey* | The subscribe key obtained from your
PubNub account. Required when subscribing to channels or listening for presence
events | null | false | MEDIUM
|===
diff --git
a/connectors/camel-pubnub-kafka-connector/src/main/docs/camel-pubnub-kafka-source-connector.adoc
b/connectors/camel-pubnub-kafka-connector/src/main/docs/camel-pubnub-kafka-source-connector.adoc
index d1b3484..4c85e6b 100644
---
a/connectors/camel-pubnub-kafka-connector/src/main/docs/camel-pubnub-kafka-source-connector.adoc
+++
b/connectors/camel-pubnub-kafka-connector/src/main/docs/camel-pubnub-kafka-source-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.pubnub.CamelPubnubSourceConnecto
----
-The camel-pubnub source connector supports 15 options, which are listed below.
+The camel-pubnub source connector supports 24 options, which are listed below.
@@ -44,8 +44,17 @@ The camel-pubnub source connector supports 15 options, which
are listed below.
| *camel.source.endpoint.secretKey* | The secret key used for message signing.
| null | false | MEDIUM
| *camel.source.endpoint.secure* | Use SSL for secure transmission. | true |
false | MEDIUM
| *camel.source.endpoint.subscribeKey* | The subscribe key obtained from your
PubNub account. Required when subscribing to channels or listening for presence
events | null | false | MEDIUM
+| *camel.component.pubnub.configuration* | The component configurations | null
| false | MEDIUM
+| *camel.component.pubnub.uuid* | UUID to be used as a device identifier, a
default UUID is generated if not passed. | null | false | MEDIUM
| *camel.component.pubnub.bridgeErrorHandler* | Allows for bridging the
consumer to the Camel routing Error Handler, which mean any exceptions occurred
while the consumer is trying to pickup incoming messages, or the likes, will
now be processed as a message and handled by the routing Error Handler. By
default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal
with exceptions, that will be logged at WARN or ERROR level and ignored. |
false | false | MEDIUM
+| *camel.component.pubnub.withPresence* | Also subscribe to related presence
information | false | false | MEDIUM
| *camel.component.pubnub.autowiredEnabled* | Whether autowiring is enabled.
This is used for automatic autowiring options (the option must be marked as
autowired) by looking up in the registry to find if there is a single instance
of matching type, which then gets configured on the component. This can be used
for automatic configuring JDBC data sources, JMS connection factories, AWS
Clients, etc. | true | false | MEDIUM
+| *camel.component.pubnub.authKey* | If Access Manager is utilized, client
will use this authKey in all restricted requests. | null | false | MEDIUM
+| *camel.component.pubnub.cipherKey* | If cipher is passed, all communications
to/from PubNub will be encrypted. | null | false | MEDIUM
+| *camel.component.pubnub.publishKey* | The publish key obtained from your
PubNub account. Required when publishing messages. | null | false | MEDIUM
+| *camel.component.pubnub.secretKey* | The secret key used for message
signing. | null | false | MEDIUM
+| *camel.component.pubnub.secure* | Use SSL for secure transmission. | true |
false | MEDIUM
+| *camel.component.pubnub.subscribeKey* | The subscribe key obtained from your
PubNub account. Required when subscribing to channels or listening for presence
events | null | false | MEDIUM
|===
diff --git
a/connectors/camel-pubnub-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/pubnub/CamelPubnubSinkConnectorConfig.java
b/connectors/camel-pubnub-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/pubnub/CamelPubnubSinkConnectorConfig.java
index 3a4211b..e49be9e 100644
---
a/connectors/camel-pubnub-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/pubnub/CamelPubnubSinkConnectorConfig.java
+++
b/connectors/camel-pubnub-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/pubnub/CamelPubnubSinkConnectorConfig.java
@@ -57,12 +57,39 @@ public class CamelPubnubSinkConnectorConfig extends
CamelSinkConnectorConfig {
public static final String CAMEL_SINK_PUBNUB_ENDPOINT_SUBSCRIBE_KEY_CONF =
"camel.sink.endpoint.subscribeKey";
public static final String CAMEL_SINK_PUBNUB_ENDPOINT_SUBSCRIBE_KEY_DOC =
"The subscribe key obtained from your PubNub account. Required when subscribing
to channels or listening for presence events";
public static final String
CAMEL_SINK_PUBNUB_ENDPOINT_SUBSCRIBE_KEY_DEFAULT = null;
+ public static final String CAMEL_SINK_PUBNUB_COMPONENT_CONFIGURATION_CONF
= "camel.component.pubnub.configuration";
+ public static final String CAMEL_SINK_PUBNUB_COMPONENT_CONFIGURATION_DOC =
"The component configurations";
+ public static final String
CAMEL_SINK_PUBNUB_COMPONENT_CONFIGURATION_DEFAULT = null;
+ public static final String CAMEL_SINK_PUBNUB_COMPONENT_UUID_CONF =
"camel.component.pubnub.uuid";
+ public static final String CAMEL_SINK_PUBNUB_COMPONENT_UUID_DOC = "UUID to
be used as a device identifier, a default UUID is generated if not passed.";
+ public static final String CAMEL_SINK_PUBNUB_COMPONENT_UUID_DEFAULT = null;
public static final String
CAMEL_SINK_PUBNUB_COMPONENT_LAZY_START_PRODUCER_CONF =
"camel.component.pubnub.lazyStartProducer";
public static final String
CAMEL_SINK_PUBNUB_COMPONENT_LAZY_START_PRODUCER_DOC = "Whether the producer
should be started lazy (on the first message). By starting lazy you can use
this to allow CamelContext and routes to startup in situations where a producer
may otherwise fail during starting and cause the route to fail being started.
By deferring this startup to be lazy then the startup failure can be handled
during routing messages via Camel's routing error handlers. Beware that wh [...]
public static final Boolean
CAMEL_SINK_PUBNUB_COMPONENT_LAZY_START_PRODUCER_DEFAULT = false;
+ public static final String CAMEL_SINK_PUBNUB_COMPONENT_OPERATION_CONF =
"camel.component.pubnub.operation";
+ public static final String CAMEL_SINK_PUBNUB_COMPONENT_OPERATION_DOC =
"The operation to perform. PUBLISH: Default. Send a message to all subscribers
of a channel. FIRE: allows the client to send a message to BLOCKS Event
Handlers. These messages will go directly to any Event Handlers registered on
the channel. HERENOW: Obtain information about the current state of a channel
including a list of unique user-ids currently subscribed to the channel and the
total occupancy count. WHERENO [...]
+ public static final String CAMEL_SINK_PUBNUB_COMPONENT_OPERATION_DEFAULT =
null;
public static final String
CAMEL_SINK_PUBNUB_COMPONENT_AUTOWIRED_ENABLED_CONF =
"camel.component.pubnub.autowiredEnabled";
public static final String
CAMEL_SINK_PUBNUB_COMPONENT_AUTOWIRED_ENABLED_DOC = "Whether autowiring is
enabled. This is used for automatic autowiring options (the option must be
marked as autowired) by looking up in the registry to find if there is a single
instance of matching type, which then gets configured on the component. This
can be used for automatic configuring JDBC data sources, JMS connection
factories, AWS Clients, etc.";
public static final Boolean
CAMEL_SINK_PUBNUB_COMPONENT_AUTOWIRED_ENABLED_DEFAULT = true;
+ public static final String CAMEL_SINK_PUBNUB_COMPONENT_AUTH_KEY_CONF =
"camel.component.pubnub.authKey";
+ public static final String CAMEL_SINK_PUBNUB_COMPONENT_AUTH_KEY_DOC = "If
Access Manager is utilized, client will use this authKey in all restricted
requests.";
+ public static final String CAMEL_SINK_PUBNUB_COMPONENT_AUTH_KEY_DEFAULT =
null;
+ public static final String CAMEL_SINK_PUBNUB_COMPONENT_CIPHER_KEY_CONF =
"camel.component.pubnub.cipherKey";
+ public static final String CAMEL_SINK_PUBNUB_COMPONENT_CIPHER_KEY_DOC =
"If cipher is passed, all communications to/from PubNub will be encrypted.";
+ public static final String CAMEL_SINK_PUBNUB_COMPONENT_CIPHER_KEY_DEFAULT
= null;
+ public static final String CAMEL_SINK_PUBNUB_COMPONENT_PUBLISH_KEY_CONF =
"camel.component.pubnub.publishKey";
+ public static final String CAMEL_SINK_PUBNUB_COMPONENT_PUBLISH_KEY_DOC =
"The publish key obtained from your PubNub account. Required when publishing
messages.";
+ public static final String CAMEL_SINK_PUBNUB_COMPONENT_PUBLISH_KEY_DEFAULT
= null;
+ public static final String CAMEL_SINK_PUBNUB_COMPONENT_SECRET_KEY_CONF =
"camel.component.pubnub.secretKey";
+ public static final String CAMEL_SINK_PUBNUB_COMPONENT_SECRET_KEY_DOC =
"The secret key used for message signing.";
+ public static final String CAMEL_SINK_PUBNUB_COMPONENT_SECRET_KEY_DEFAULT
= null;
+ public static final String CAMEL_SINK_PUBNUB_COMPONENT_SECURE_CONF =
"camel.component.pubnub.secure";
+ public static final String CAMEL_SINK_PUBNUB_COMPONENT_SECURE_DOC = "Use
SSL for secure transmission.";
+ public static final Boolean CAMEL_SINK_PUBNUB_COMPONENT_SECURE_DEFAULT =
true;
+ public static final String CAMEL_SINK_PUBNUB_COMPONENT_SUBSCRIBE_KEY_CONF
= "camel.component.pubnub.subscribeKey";
+ public static final String CAMEL_SINK_PUBNUB_COMPONENT_SUBSCRIBE_KEY_DOC =
"The subscribe key obtained from your PubNub account. Required when subscribing
to channels or listening for presence events";
+ public static final String
CAMEL_SINK_PUBNUB_COMPONENT_SUBSCRIBE_KEY_DEFAULT = null;
public CamelPubnubSinkConnectorConfig(
ConfigDef config,
@@ -87,8 +114,17 @@ public class CamelPubnubSinkConnectorConfig extends
CamelSinkConnectorConfig {
conf.define(CAMEL_SINK_PUBNUB_ENDPOINT_SECRET_KEY_CONF,
ConfigDef.Type.PASSWORD, CAMEL_SINK_PUBNUB_ENDPOINT_SECRET_KEY_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_PUBNUB_ENDPOINT_SECRET_KEY_DOC);
conf.define(CAMEL_SINK_PUBNUB_ENDPOINT_SECURE_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_PUBNUB_ENDPOINT_SECURE_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_PUBNUB_ENDPOINT_SECURE_DOC);
conf.define(CAMEL_SINK_PUBNUB_ENDPOINT_SUBSCRIBE_KEY_CONF,
ConfigDef.Type.PASSWORD, CAMEL_SINK_PUBNUB_ENDPOINT_SUBSCRIBE_KEY_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_PUBNUB_ENDPOINT_SUBSCRIBE_KEY_DOC);
+ conf.define(CAMEL_SINK_PUBNUB_COMPONENT_CONFIGURATION_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_PUBNUB_COMPONENT_CONFIGURATION_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_PUBNUB_COMPONENT_CONFIGURATION_DOC);
+ conf.define(CAMEL_SINK_PUBNUB_COMPONENT_UUID_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_PUBNUB_COMPONENT_UUID_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_PUBNUB_COMPONENT_UUID_DOC);
conf.define(CAMEL_SINK_PUBNUB_COMPONENT_LAZY_START_PRODUCER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_PUBNUB_COMPONENT_LAZY_START_PRODUCER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_PUBNUB_COMPONENT_LAZY_START_PRODUCER_DOC);
+ conf.define(CAMEL_SINK_PUBNUB_COMPONENT_OPERATION_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_PUBNUB_COMPONENT_OPERATION_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_PUBNUB_COMPONENT_OPERATION_DOC);
conf.define(CAMEL_SINK_PUBNUB_COMPONENT_AUTOWIRED_ENABLED_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_PUBNUB_COMPONENT_AUTOWIRED_ENABLED_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_PUBNUB_COMPONENT_AUTOWIRED_ENABLED_DOC);
+ conf.define(CAMEL_SINK_PUBNUB_COMPONENT_AUTH_KEY_CONF,
ConfigDef.Type.PASSWORD, CAMEL_SINK_PUBNUB_COMPONENT_AUTH_KEY_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_PUBNUB_COMPONENT_AUTH_KEY_DOC);
+ conf.define(CAMEL_SINK_PUBNUB_COMPONENT_CIPHER_KEY_CONF,
ConfigDef.Type.PASSWORD, CAMEL_SINK_PUBNUB_COMPONENT_CIPHER_KEY_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_PUBNUB_COMPONENT_CIPHER_KEY_DOC);
+ conf.define(CAMEL_SINK_PUBNUB_COMPONENT_PUBLISH_KEY_CONF,
ConfigDef.Type.PASSWORD, CAMEL_SINK_PUBNUB_COMPONENT_PUBLISH_KEY_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_PUBNUB_COMPONENT_PUBLISH_KEY_DOC);
+ conf.define(CAMEL_SINK_PUBNUB_COMPONENT_SECRET_KEY_CONF,
ConfigDef.Type.PASSWORD, CAMEL_SINK_PUBNUB_COMPONENT_SECRET_KEY_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_PUBNUB_COMPONENT_SECRET_KEY_DOC);
+ conf.define(CAMEL_SINK_PUBNUB_COMPONENT_SECURE_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_PUBNUB_COMPONENT_SECURE_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_PUBNUB_COMPONENT_SECURE_DOC);
+ conf.define(CAMEL_SINK_PUBNUB_COMPONENT_SUBSCRIBE_KEY_CONF,
ConfigDef.Type.PASSWORD, CAMEL_SINK_PUBNUB_COMPONENT_SUBSCRIBE_KEY_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_PUBNUB_COMPONENT_SUBSCRIBE_KEY_DOC);
return conf;
}
}
\ No newline at end of file
diff --git
a/connectors/camel-pubnub-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/pubnub/CamelPubnubSourceConnectorConfig.java
b/connectors/camel-pubnub-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/pubnub/CamelPubnubSourceConnectorConfig.java
index 29bdcd6..732a028 100644
---
a/connectors/camel-pubnub-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/pubnub/CamelPubnubSourceConnectorConfig.java
+++
b/connectors/camel-pubnub-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/pubnub/CamelPubnubSourceConnectorConfig.java
@@ -65,12 +65,39 @@ public class CamelPubnubSourceConnectorConfig
public static final String CAMEL_SOURCE_PUBNUB_ENDPOINT_SUBSCRIBE_KEY_CONF
= "camel.source.endpoint.subscribeKey";
public static final String CAMEL_SOURCE_PUBNUB_ENDPOINT_SUBSCRIBE_KEY_DOC
= "The subscribe key obtained from your PubNub account. Required when
subscribing to channels or listening for presence events";
public static final String
CAMEL_SOURCE_PUBNUB_ENDPOINT_SUBSCRIBE_KEY_DEFAULT = null;
+ public static final String
CAMEL_SOURCE_PUBNUB_COMPONENT_CONFIGURATION_CONF =
"camel.component.pubnub.configuration";
+ public static final String CAMEL_SOURCE_PUBNUB_COMPONENT_CONFIGURATION_DOC
= "The component configurations";
+ public static final String
CAMEL_SOURCE_PUBNUB_COMPONENT_CONFIGURATION_DEFAULT = null;
+ public static final String CAMEL_SOURCE_PUBNUB_COMPONENT_UUID_CONF =
"camel.component.pubnub.uuid";
+ public static final String CAMEL_SOURCE_PUBNUB_COMPONENT_UUID_DOC = "UUID
to be used as a device identifier, a default UUID is generated if not passed.";
+ public static final String CAMEL_SOURCE_PUBNUB_COMPONENT_UUID_DEFAULT =
null;
public static final String
CAMEL_SOURCE_PUBNUB_COMPONENT_BRIDGE_ERROR_HANDLER_CONF =
"camel.component.pubnub.bridgeErrorHandler";
public static final String
CAMEL_SOURCE_PUBNUB_COMPONENT_BRIDGE_ERROR_HANDLER_DOC = "Allows for bridging
the consumer to the Camel routing Error Handler, which mean any exceptions
occurred while the consumer is trying to pickup incoming messages, or the
likes, will now be processed as a message and handled by the routing Error
Handler. By default the consumer will use the
org.apache.camel.spi.ExceptionHandler to deal with exceptions, that will be
logged at WARN or ERROR level and ignored.";
public static final Boolean
CAMEL_SOURCE_PUBNUB_COMPONENT_BRIDGE_ERROR_HANDLER_DEFAULT = false;
+ public static final String
CAMEL_SOURCE_PUBNUB_COMPONENT_WITH_PRESENCE_CONF =
"camel.component.pubnub.withPresence";
+ public static final String CAMEL_SOURCE_PUBNUB_COMPONENT_WITH_PRESENCE_DOC
= "Also subscribe to related presence information";
+ public static final Boolean
CAMEL_SOURCE_PUBNUB_COMPONENT_WITH_PRESENCE_DEFAULT = false;
public static final String
CAMEL_SOURCE_PUBNUB_COMPONENT_AUTOWIRED_ENABLED_CONF =
"camel.component.pubnub.autowiredEnabled";
public static final String
CAMEL_SOURCE_PUBNUB_COMPONENT_AUTOWIRED_ENABLED_DOC = "Whether autowiring is
enabled. This is used for automatic autowiring options (the option must be
marked as autowired) by looking up in the registry to find if there is a single
instance of matching type, which then gets configured on the component. This
can be used for automatic configuring JDBC data sources, JMS connection
factories, AWS Clients, etc.";
public static final Boolean
CAMEL_SOURCE_PUBNUB_COMPONENT_AUTOWIRED_ENABLED_DEFAULT = true;
+ public static final String CAMEL_SOURCE_PUBNUB_COMPONENT_AUTH_KEY_CONF =
"camel.component.pubnub.authKey";
+ public static final String CAMEL_SOURCE_PUBNUB_COMPONENT_AUTH_KEY_DOC =
"If Access Manager is utilized, client will use this authKey in all restricted
requests.";
+ public static final String CAMEL_SOURCE_PUBNUB_COMPONENT_AUTH_KEY_DEFAULT
= null;
+ public static final String CAMEL_SOURCE_PUBNUB_COMPONENT_CIPHER_KEY_CONF =
"camel.component.pubnub.cipherKey";
+ public static final String CAMEL_SOURCE_PUBNUB_COMPONENT_CIPHER_KEY_DOC =
"If cipher is passed, all communications to/from PubNub will be encrypted.";
+ public static final String
CAMEL_SOURCE_PUBNUB_COMPONENT_CIPHER_KEY_DEFAULT = null;
+ public static final String CAMEL_SOURCE_PUBNUB_COMPONENT_PUBLISH_KEY_CONF
= "camel.component.pubnub.publishKey";
+ public static final String CAMEL_SOURCE_PUBNUB_COMPONENT_PUBLISH_KEY_DOC =
"The publish key obtained from your PubNub account. Required when publishing
messages.";
+ public static final String
CAMEL_SOURCE_PUBNUB_COMPONENT_PUBLISH_KEY_DEFAULT = null;
+ public static final String CAMEL_SOURCE_PUBNUB_COMPONENT_SECRET_KEY_CONF =
"camel.component.pubnub.secretKey";
+ public static final String CAMEL_SOURCE_PUBNUB_COMPONENT_SECRET_KEY_DOC =
"The secret key used for message signing.";
+ public static final String
CAMEL_SOURCE_PUBNUB_COMPONENT_SECRET_KEY_DEFAULT = null;
+ public static final String CAMEL_SOURCE_PUBNUB_COMPONENT_SECURE_CONF =
"camel.component.pubnub.secure";
+ public static final String CAMEL_SOURCE_PUBNUB_COMPONENT_SECURE_DOC = "Use
SSL for secure transmission.";
+ public static final Boolean CAMEL_SOURCE_PUBNUB_COMPONENT_SECURE_DEFAULT =
true;
+ public static final String
CAMEL_SOURCE_PUBNUB_COMPONENT_SUBSCRIBE_KEY_CONF =
"camel.component.pubnub.subscribeKey";
+ public static final String CAMEL_SOURCE_PUBNUB_COMPONENT_SUBSCRIBE_KEY_DOC
= "The subscribe key obtained from your PubNub account. Required when
subscribing to channels or listening for presence events";
+ public static final String
CAMEL_SOURCE_PUBNUB_COMPONENT_SUBSCRIBE_KEY_DEFAULT = null;
public CamelPubnubSourceConnectorConfig(
ConfigDef config,
@@ -97,8 +124,17 @@ public class CamelPubnubSourceConnectorConfig
conf.define(CAMEL_SOURCE_PUBNUB_ENDPOINT_SECRET_KEY_CONF,
ConfigDef.Type.PASSWORD, CAMEL_SOURCE_PUBNUB_ENDPOINT_SECRET_KEY_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_PUBNUB_ENDPOINT_SECRET_KEY_DOC);
conf.define(CAMEL_SOURCE_PUBNUB_ENDPOINT_SECURE_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_PUBNUB_ENDPOINT_SECURE_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_PUBNUB_ENDPOINT_SECURE_DOC);
conf.define(CAMEL_SOURCE_PUBNUB_ENDPOINT_SUBSCRIBE_KEY_CONF,
ConfigDef.Type.PASSWORD, CAMEL_SOURCE_PUBNUB_ENDPOINT_SUBSCRIBE_KEY_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_PUBNUB_ENDPOINT_SUBSCRIBE_KEY_DOC);
+ conf.define(CAMEL_SOURCE_PUBNUB_COMPONENT_CONFIGURATION_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_PUBNUB_COMPONENT_CONFIGURATION_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_PUBNUB_COMPONENT_CONFIGURATION_DOC);
+ conf.define(CAMEL_SOURCE_PUBNUB_COMPONENT_UUID_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_PUBNUB_COMPONENT_UUID_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_PUBNUB_COMPONENT_UUID_DOC);
conf.define(CAMEL_SOURCE_PUBNUB_COMPONENT_BRIDGE_ERROR_HANDLER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SOURCE_PUBNUB_COMPONENT_BRIDGE_ERROR_HANDLER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_PUBNUB_COMPONENT_BRIDGE_ERROR_HANDLER_DOC);
+ conf.define(CAMEL_SOURCE_PUBNUB_COMPONENT_WITH_PRESENCE_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_PUBNUB_COMPONENT_WITH_PRESENCE_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_PUBNUB_COMPONENT_WITH_PRESENCE_DOC);
conf.define(CAMEL_SOURCE_PUBNUB_COMPONENT_AUTOWIRED_ENABLED_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SOURCE_PUBNUB_COMPONENT_AUTOWIRED_ENABLED_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_PUBNUB_COMPONENT_AUTOWIRED_ENABLED_DOC);
+ conf.define(CAMEL_SOURCE_PUBNUB_COMPONENT_AUTH_KEY_CONF,
ConfigDef.Type.PASSWORD, CAMEL_SOURCE_PUBNUB_COMPONENT_AUTH_KEY_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_PUBNUB_COMPONENT_AUTH_KEY_DOC);
+ conf.define(CAMEL_SOURCE_PUBNUB_COMPONENT_CIPHER_KEY_CONF,
ConfigDef.Type.PASSWORD, CAMEL_SOURCE_PUBNUB_COMPONENT_CIPHER_KEY_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_PUBNUB_COMPONENT_CIPHER_KEY_DOC);
+ conf.define(CAMEL_SOURCE_PUBNUB_COMPONENT_PUBLISH_KEY_CONF,
ConfigDef.Type.PASSWORD, CAMEL_SOURCE_PUBNUB_COMPONENT_PUBLISH_KEY_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_PUBNUB_COMPONENT_PUBLISH_KEY_DOC);
+ conf.define(CAMEL_SOURCE_PUBNUB_COMPONENT_SECRET_KEY_CONF,
ConfigDef.Type.PASSWORD, CAMEL_SOURCE_PUBNUB_COMPONENT_SECRET_KEY_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_PUBNUB_COMPONENT_SECRET_KEY_DOC);
+ conf.define(CAMEL_SOURCE_PUBNUB_COMPONENT_SECURE_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_PUBNUB_COMPONENT_SECURE_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_PUBNUB_COMPONENT_SECURE_DOC);
+ conf.define(CAMEL_SOURCE_PUBNUB_COMPONENT_SUBSCRIBE_KEY_CONF,
ConfigDef.Type.PASSWORD, CAMEL_SOURCE_PUBNUB_COMPONENT_SUBSCRIBE_KEY_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_PUBNUB_COMPONENT_SUBSCRIBE_KEY_DOC);
return conf;
}
}
\ No newline at end of file
diff --git
a/connectors/camel-smpp-kafka-connector/src/generated/resources/camel-smpp-sink.json
b/connectors/camel-smpp-kafka-connector/src/generated/resources/camel-smpp-sink.json
index 2ac1d32..cbcaa0d 100644
---
a/connectors/camel-smpp-kafka-connector/src/generated/resources/camel-smpp-sink.json
+++
b/connectors/camel-smpp-kafka-connector/src/generated/resources/camel-smpp-sink.json
@@ -269,6 +269,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.sink.endpoint.singleDLR": {
+ "name": "camel.sink.endpoint.singleDLR",
+ "description": "When true, the SMSC delivery receipt
would be requested only for the last segment of a multi-segment (long) message.
For short messages, with only 1 segment the behaviour is unchanged.",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.transactionTimer": {
"name": "camel.sink.endpoint.transactionTimer",
"description": "Defines the maximum period of
inactivity allowed after a transaction, after which an SMPP entity may assume
that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME).",
@@ -610,6 +617,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.smpp.singleDLR": {
+ "name": "camel.component.smpp.singleDLR",
+ "description": "When true, the SMSC delivery receipt
would be requested only for the last segment of a multi-segment (long) message.
For short messages, with only 1 segment the behaviour is unchanged.",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.smpp.transactionTimer": {
"name": "camel.component.smpp.transactionTimer",
"description": "Defines the maximum period of
inactivity allowed after a transaction, after which an SMPP entity may assume
that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME).",
diff --git
a/connectors/camel-smpp-kafka-connector/src/generated/resources/camel-smpp-source.json
b/connectors/camel-smpp-kafka-connector/src/generated/resources/camel-smpp-source.json
index 61f5679..c9775e6 100644
---
a/connectors/camel-smpp-kafka-connector/src/generated/resources/camel-smpp-source.json
+++
b/connectors/camel-smpp-kafka-connector/src/generated/resources/camel-smpp-source.json
@@ -119,6 +119,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.source.endpoint.singleDLR": {
+ "name": "camel.source.endpoint.singleDLR",
+ "description": "When true, the SMSC delivery receipt
would be requested only for the last segment of a multi-segment (long) message.
For short messages, with only 1 segment the behaviour is unchanged.",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.source.endpoint.transactionTimer": {
"name": "camel.source.endpoint.transactionTimer",
"description": "Defines the maximum period of
inactivity allowed after a transaction, after which an SMPP entity may assume
that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME).",
@@ -293,6 +300,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.smpp.singleDLR": {
+ "name": "camel.component.smpp.singleDLR",
+ "description": "When true, the SMSC delivery receipt
would be requested only for the last segment of a multi-segment (long) message.
For short messages, with only 1 segment the behaviour is unchanged.",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.smpp.transactionTimer": {
"name": "camel.component.smpp.transactionTimer",
"description": "Defines the maximum period of
inactivity allowed after a transaction, after which an SMPP entity may assume
that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME).",
diff --git
a/connectors/camel-smpp-kafka-connector/src/main/docs/camel-smpp-kafka-sink-connector.adoc
b/connectors/camel-smpp-kafka-connector/src/main/docs/camel-smpp-kafka-sink-connector.adoc
index 0a071e3..c89810d 100644
---
a/connectors/camel-smpp-kafka-connector/src/main/docs/camel-smpp-kafka-sink-connector.adoc
+++
b/connectors/camel-smpp-kafka-connector/src/main/docs/camel-smpp-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.smpp.CamelSmppSinkConnector
----
-The camel-smpp sink connector supports 76 options, which are listed below.
+The camel-smpp sink connector supports 78 options, which are listed below.
@@ -57,6 +57,7 @@ The camel-smpp sink connector supports 76 options, which are
listed below.
| *camel.sink.endpoint.pduProcessorDegree* | Sets the number of threads which
can read PDU and process them in parallel. | "3" | false | MEDIUM
| *camel.sink.endpoint.pduProcessorQueueCapacity* | Sets the capacity of the
working queue for PDU processing. | "100" | false | MEDIUM
| *camel.sink.endpoint.sessionStateListener* | You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed. | null | false | MEDIUM
+| *camel.sink.endpoint.singleDLR* | When true, the SMSC delivery receipt would
be requested only for the last segment of a multi-segment (long) message. For
short messages, with only 1 segment the behaviour is unchanged. | false | false
| MEDIUM
| *camel.sink.endpoint.transactionTimer* | Defines the maximum period of
inactivity allowed after a transaction, after which an SMPP entity may assume
that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME). | "10000" | false | MEDIUM
| *camel.sink.endpoint.alphabet* | Defines encoding of data according the SMPP
3.4 specification, section 5.2.19. 0: SMSC Default Alphabet 4: 8 bit Alphabet
8: UCS2 Alphabet One of: [0] [4] [8] | null | false | MEDIUM
| *camel.sink.endpoint.dataCoding* | Defines the data coding according the
SMPP 3.4 specification, section 5.2.19. Example data encodings are: 0: SMSC
Default Alphabet 3: Latin 1 (ISO-8859-1) 4: Octet unspecified (8-bit binary) 8:
UCS2 (ISO/IEC-10646) 13: Extended Kanji JIS(X 0212-1990) | null | false | MEDIUM
@@ -95,6 +96,7 @@ The camel-smpp sink connector supports 76 options, which are
listed below.
| *camel.component.smpp.pduProcessorDegree* | Sets the number of threads which
can read PDU and process them in parallel. | "3" | false | MEDIUM
| *camel.component.smpp.pduProcessorQueueCapacity* | Sets the capacity of the
working queue for PDU processing. | "100" | false | MEDIUM
| *camel.component.smpp.sessionStateListener* | You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed. | null | false | MEDIUM
+| *camel.component.smpp.singleDLR* | When true, the SMSC delivery receipt
would be requested only for the last segment of a multi-segment (long) message.
For short messages, with only 1 segment the behaviour is unchanged. | false |
false | MEDIUM
| *camel.component.smpp.transactionTimer* | Defines the maximum period of
inactivity allowed after a transaction, after which an SMPP entity may assume
that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME). | "10000" | false | MEDIUM
| *camel.component.smpp.alphabet* | Defines encoding of data according the
SMPP 3.4 specification, section 5.2.19. 0: SMSC Default Alphabet 4: 8 bit
Alphabet 8: UCS2 Alphabet One of: [0] [4] [8] | null | false | MEDIUM
| *camel.component.smpp.dataCoding* | Defines the data coding according the
SMPP 3.4 specification, section 5.2.19. Example data encodings are: 0: SMSC
Default Alphabet 3: Latin 1 (ISO-8859-1) 4: Octet unspecified (8-bit binary) 8:
UCS2 (ISO/IEC-10646) 13: Extended Kanji JIS(X 0212-1990) | null | false | MEDIUM
diff --git
a/connectors/camel-smpp-kafka-connector/src/main/docs/camel-smpp-kafka-source-connector.adoc
b/connectors/camel-smpp-kafka-connector/src/main/docs/camel-smpp-kafka-source-connector.adoc
index 57fc067..63349de 100644
---
a/connectors/camel-smpp-kafka-connector/src/main/docs/camel-smpp-kafka-source-connector.adoc
+++
b/connectors/camel-smpp-kafka-connector/src/main/docs/camel-smpp-kafka-source-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.smpp.CamelSmppSourceConnector
----
-The camel-smpp source connector supports 52 options, which are listed below.
+The camel-smpp source connector supports 54 options, which are listed below.
@@ -46,6 +46,7 @@ The camel-smpp source connector supports 52 options, which
are listed below.
| *camel.source.endpoint.pduProcessorDegree* | Sets the number of threads
which can read PDU and process them in parallel. | "3" | false | MEDIUM
| *camel.source.endpoint.pduProcessorQueueCapacity* | Sets the capacity of the
working queue for PDU processing. | "100" | false | MEDIUM
| *camel.source.endpoint.sessionStateListener* | You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed. | null | false | MEDIUM
+| *camel.source.endpoint.singleDLR* | When true, the SMSC delivery receipt
would be requested only for the last segment of a multi-segment (long) message.
For short messages, with only 1 segment the behaviour is unchanged. | false |
false | MEDIUM
| *camel.source.endpoint.transactionTimer* | Defines the maximum period of
inactivity allowed after a transaction, after which an SMPP entity may assume
that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME). | "10000" | false | MEDIUM
| *camel.source.endpoint.alphabet* | Defines encoding of data according the
SMPP 3.4 specification, section 5.2.19. 0: SMSC Default Alphabet 4: 8 bit
Alphabet 8: UCS2 Alphabet One of: [0] [4] [8] | null | false | MEDIUM
| *camel.source.endpoint.dataCoding* | Defines the data coding according the
SMPP 3.4 specification, section 5.2.19. Example data encodings are: 0: SMSC
Default Alphabet 3: Latin 1 (ISO-8859-1) 4: Octet unspecified (8-bit binary) 8:
UCS2 (ISO/IEC-10646) 13: Extended Kanji JIS(X 0212-1990) | null | false | MEDIUM
@@ -71,6 +72,7 @@ The camel-smpp source connector supports 52 options, which
are listed below.
| *camel.component.smpp.pduProcessorDegree* | Sets the number of threads which
can read PDU and process them in parallel. | "3" | false | MEDIUM
| *camel.component.smpp.pduProcessorQueueCapacity* | Sets the capacity of the
working queue for PDU processing. | "100" | false | MEDIUM
| *camel.component.smpp.sessionStateListener* | You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed. | null | false | MEDIUM
+| *camel.component.smpp.singleDLR* | When true, the SMSC delivery receipt
would be requested only for the last segment of a multi-segment (long) message.
For short messages, with only 1 segment the behaviour is unchanged. | false |
false | MEDIUM
| *camel.component.smpp.transactionTimer* | Defines the maximum period of
inactivity allowed after a transaction, after which an SMPP entity may assume
that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME). | "10000" | false | MEDIUM
| *camel.component.smpp.alphabet* | Defines encoding of data according the
SMPP 3.4 specification, section 5.2.19. 0: SMSC Default Alphabet 4: 8 bit
Alphabet 8: UCS2 Alphabet One of: [0] [4] [8] | null | false | MEDIUM
| *camel.component.smpp.dataCoding* | Defines the data coding according the
SMPP 3.4 specification, section 5.2.19. Example data encodings are: 0: SMSC
Default Alphabet 3: Latin 1 (ISO-8859-1) 4: Octet unspecified (8-bit binary) 8:
UCS2 (ISO/IEC-10646) 13: Extended Kanji JIS(X 0212-1990) | null | false | MEDIUM
diff --git
a/connectors/camel-smpp-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/smpp/CamelSmppSinkConnectorConfig.java
b/connectors/camel-smpp-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/smpp/CamelSmppSinkConnectorConfig.java
index 0799be5..688e957 100644
---
a/connectors/camel-smpp-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/smpp/CamelSmppSinkConnectorConfig.java
+++
b/connectors/camel-smpp-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/smpp/CamelSmppSinkConnectorConfig.java
@@ -102,6 +102,9 @@ public class CamelSmppSinkConnectorConfig extends
CamelSinkConnectorConfig {
public static final String
CAMEL_SINK_SMPP_ENDPOINT_SESSION_STATE_LISTENER_CONF =
"camel.sink.endpoint.sessionStateListener";
public static final String
CAMEL_SINK_SMPP_ENDPOINT_SESSION_STATE_LISTENER_DOC = "You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed.";
public static final String
CAMEL_SINK_SMPP_ENDPOINT_SESSION_STATE_LISTENER_DEFAULT = null;
+ public static final String CAMEL_SINK_SMPP_ENDPOINT_SINGLE_DLRCONF =
"camel.sink.endpoint.singleDLR";
+ public static final String CAMEL_SINK_SMPP_ENDPOINT_SINGLE_DLRDOC = "When
true, the SMSC delivery receipt would be requested only for the last segment of
a multi-segment (long) message. For short messages, with only 1 segment the
behaviour is unchanged.";
+ public static final Boolean CAMEL_SINK_SMPP_ENDPOINT_SINGLE_DLRDEFAULT =
false;
public static final String CAMEL_SINK_SMPP_ENDPOINT_TRANSACTION_TIMER_CONF
= "camel.sink.endpoint.transactionTimer";
public static final String CAMEL_SINK_SMPP_ENDPOINT_TRANSACTION_TIMER_DOC
= "Defines the maximum period of inactivity allowed after a transaction, after
which an SMPP entity may assume that the session is no longer active. This
timer may be active on either communicating SMPP entity (i.e. SMSC or ESME).";
public static final String
CAMEL_SINK_SMPP_ENDPOINT_TRANSACTION_TIMER_DEFAULT = "10000";
@@ -216,6 +219,9 @@ public class CamelSmppSinkConnectorConfig extends
CamelSinkConnectorConfig {
public static final String
CAMEL_SINK_SMPP_COMPONENT_SESSION_STATE_LISTENER_CONF =
"camel.component.smpp.sessionStateListener";
public static final String
CAMEL_SINK_SMPP_COMPONENT_SESSION_STATE_LISTENER_DOC = "You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed.";
public static final String
CAMEL_SINK_SMPP_COMPONENT_SESSION_STATE_LISTENER_DEFAULT = null;
+ public static final String CAMEL_SINK_SMPP_COMPONENT_SINGLE_DLRCONF =
"camel.component.smpp.singleDLR";
+ public static final String CAMEL_SINK_SMPP_COMPONENT_SINGLE_DLRDOC = "When
true, the SMSC delivery receipt would be requested only for the last segment of
a multi-segment (long) message. For short messages, with only 1 segment the
behaviour is unchanged.";
+ public static final Boolean CAMEL_SINK_SMPP_COMPONENT_SINGLE_DLRDEFAULT =
false;
public static final String
CAMEL_SINK_SMPP_COMPONENT_TRANSACTION_TIMER_CONF =
"camel.component.smpp.transactionTimer";
public static final String CAMEL_SINK_SMPP_COMPONENT_TRANSACTION_TIMER_DOC
= "Defines the maximum period of inactivity allowed after a transaction, after
which an SMPP entity may assume that the session is no longer active. This
timer may be active on either communicating SMPP entity (i.e. SMSC or ESME).";
public static final String
CAMEL_SINK_SMPP_COMPONENT_TRANSACTION_TIMER_DEFAULT = "10000";
@@ -291,6 +297,7 @@ public class CamelSmppSinkConnectorConfig extends
CamelSinkConnectorConfig {
conf.define(CAMEL_SINK_SMPP_ENDPOINT_PDU_PROCESSOR_DEGREE_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SMPP_ENDPOINT_PDU_PROCESSOR_DEGREE_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SMPP_ENDPOINT_PDU_PROCESSOR_DEGREE_DOC);
conf.define(CAMEL_SINK_SMPP_ENDPOINT_PDU_PROCESSOR_QUEUE_CAPACITY_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_SMPP_ENDPOINT_PDU_PROCESSOR_QUEUE_CAPACITY_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_SMPP_ENDPOINT_PDU_PROCESSOR_QUEUE_CAPACITY_DOC);
conf.define(CAMEL_SINK_SMPP_ENDPOINT_SESSION_STATE_LISTENER_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SMPP_ENDPOINT_SESSION_STATE_LISTENER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_SMPP_ENDPOINT_SESSION_STATE_LISTENER_DOC);
+ conf.define(CAMEL_SINK_SMPP_ENDPOINT_SINGLE_DLRCONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_SMPP_ENDPOINT_SINGLE_DLRDEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SMPP_ENDPOINT_SINGLE_DLRDOC);
conf.define(CAMEL_SINK_SMPP_ENDPOINT_TRANSACTION_TIMER_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SMPP_ENDPOINT_TRANSACTION_TIMER_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SMPP_ENDPOINT_TRANSACTION_TIMER_DOC);
conf.define(CAMEL_SINK_SMPP_ENDPOINT_ALPHABET_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SMPP_ENDPOINT_ALPHABET_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SMPP_ENDPOINT_ALPHABET_DOC);
conf.define(CAMEL_SINK_SMPP_ENDPOINT_DATA_CODING_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SMPP_ENDPOINT_DATA_CODING_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SMPP_ENDPOINT_DATA_CODING_DOC);
@@ -329,6 +336,7 @@ public class CamelSmppSinkConnectorConfig extends
CamelSinkConnectorConfig {
conf.define(CAMEL_SINK_SMPP_COMPONENT_PDU_PROCESSOR_DEGREE_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SMPP_COMPONENT_PDU_PROCESSOR_DEGREE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_SMPP_COMPONENT_PDU_PROCESSOR_DEGREE_DOC);
conf.define(CAMEL_SINK_SMPP_COMPONENT_PDU_PROCESSOR_QUEUE_CAPACITY_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_SMPP_COMPONENT_PDU_PROCESSOR_QUEUE_CAPACITY_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_SMPP_COMPONENT_PDU_PROCESSOR_QUEUE_CAPACITY_DOC);
conf.define(CAMEL_SINK_SMPP_COMPONENT_SESSION_STATE_LISTENER_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_SMPP_COMPONENT_SESSION_STATE_LISTENER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_SMPP_COMPONENT_SESSION_STATE_LISTENER_DOC);
+ conf.define(CAMEL_SINK_SMPP_COMPONENT_SINGLE_DLRCONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_SMPP_COMPONENT_SINGLE_DLRDEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SMPP_COMPONENT_SINGLE_DLRDOC);
conf.define(CAMEL_SINK_SMPP_COMPONENT_TRANSACTION_TIMER_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SMPP_COMPONENT_TRANSACTION_TIMER_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SMPP_COMPONENT_TRANSACTION_TIMER_DOC);
conf.define(CAMEL_SINK_SMPP_COMPONENT_ALPHABET_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SMPP_COMPONENT_ALPHABET_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SMPP_COMPONENT_ALPHABET_DOC);
conf.define(CAMEL_SINK_SMPP_COMPONENT_DATA_CODING_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SMPP_COMPONENT_DATA_CODING_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SMPP_COMPONENT_DATA_CODING_DOC);
diff --git
a/connectors/camel-smpp-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/smpp/CamelSmppSourceConnectorConfig.java
b/connectors/camel-smpp-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/smpp/CamelSmppSourceConnectorConfig.java
index 40aec90..e4c4a4f 100644
---
a/connectors/camel-smpp-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/smpp/CamelSmppSourceConnectorConfig.java
+++
b/connectors/camel-smpp-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/smpp/CamelSmppSourceConnectorConfig.java
@@ -71,6 +71,9 @@ public class CamelSmppSourceConnectorConfig
public static final String
CAMEL_SOURCE_SMPP_ENDPOINT_SESSION_STATE_LISTENER_CONF =
"camel.source.endpoint.sessionStateListener";
public static final String
CAMEL_SOURCE_SMPP_ENDPOINT_SESSION_STATE_LISTENER_DOC = "You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed.";
public static final String
CAMEL_SOURCE_SMPP_ENDPOINT_SESSION_STATE_LISTENER_DEFAULT = null;
+ public static final String CAMEL_SOURCE_SMPP_ENDPOINT_SINGLE_DLRCONF =
"camel.source.endpoint.singleDLR";
+ public static final String CAMEL_SOURCE_SMPP_ENDPOINT_SINGLE_DLRDOC =
"When true, the SMSC delivery receipt would be requested only for the last
segment of a multi-segment (long) message. For short messages, with only 1
segment the behaviour is unchanged.";
+ public static final Boolean CAMEL_SOURCE_SMPP_ENDPOINT_SINGLE_DLRDEFAULT =
false;
public static final String
CAMEL_SOURCE_SMPP_ENDPOINT_TRANSACTION_TIMER_CONF =
"camel.source.endpoint.transactionTimer";
public static final String
CAMEL_SOURCE_SMPP_ENDPOINT_TRANSACTION_TIMER_DOC = "Defines the maximum period
of inactivity allowed after a transaction, after which an SMPP entity may
assume that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME).";
public static final String
CAMEL_SOURCE_SMPP_ENDPOINT_TRANSACTION_TIMER_DEFAULT = "10000";
@@ -146,6 +149,9 @@ public class CamelSmppSourceConnectorConfig
public static final String
CAMEL_SOURCE_SMPP_COMPONENT_SESSION_STATE_LISTENER_CONF =
"camel.component.smpp.sessionStateListener";
public static final String
CAMEL_SOURCE_SMPP_COMPONENT_SESSION_STATE_LISTENER_DOC = "You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed.";
public static final String
CAMEL_SOURCE_SMPP_COMPONENT_SESSION_STATE_LISTENER_DEFAULT = null;
+ public static final String CAMEL_SOURCE_SMPP_COMPONENT_SINGLE_DLRCONF =
"camel.component.smpp.singleDLR";
+ public static final String CAMEL_SOURCE_SMPP_COMPONENT_SINGLE_DLRDOC =
"When true, the SMSC delivery receipt would be requested only for the last
segment of a multi-segment (long) message. For short messages, with only 1
segment the behaviour is unchanged.";
+ public static final Boolean CAMEL_SOURCE_SMPP_COMPONENT_SINGLE_DLRDEFAULT
= false;
public static final String
CAMEL_SOURCE_SMPP_COMPONENT_TRANSACTION_TIMER_CONF =
"camel.component.smpp.transactionTimer";
public static final String
CAMEL_SOURCE_SMPP_COMPONENT_TRANSACTION_TIMER_DOC = "Defines the maximum period
of inactivity allowed after a transaction, after which an SMPP entity may
assume that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME).";
public static final String
CAMEL_SOURCE_SMPP_COMPONENT_TRANSACTION_TIMER_DEFAULT = "10000";
@@ -210,6 +216,7 @@ public class CamelSmppSourceConnectorConfig
conf.define(CAMEL_SOURCE_SMPP_ENDPOINT_PDU_PROCESSOR_DEGREE_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_SMPP_ENDPOINT_PDU_PROCESSOR_DEGREE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_SMPP_ENDPOINT_PDU_PROCESSOR_DEGREE_DOC);
conf.define(CAMEL_SOURCE_SMPP_ENDPOINT_PDU_PROCESSOR_QUEUE_CAPACITY_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_SMPP_ENDPOINT_PDU_PROCESSOR_QUEUE_CAPACITY_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_SMPP_ENDPOINT_PDU_PROCESSOR_QUEUE_CAPACITY_DOC);
conf.define(CAMEL_SOURCE_SMPP_ENDPOINT_SESSION_STATE_LISTENER_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_SMPP_ENDPOINT_SESSION_STATE_LISTENER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_SMPP_ENDPOINT_SESSION_STATE_LISTENER_DOC);
+ conf.define(CAMEL_SOURCE_SMPP_ENDPOINT_SINGLE_DLRCONF,
ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_SMPP_ENDPOINT_SINGLE_DLRDEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SMPP_ENDPOINT_SINGLE_DLRDOC);
conf.define(CAMEL_SOURCE_SMPP_ENDPOINT_TRANSACTION_TIMER_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_SMPP_ENDPOINT_TRANSACTION_TIMER_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SMPP_ENDPOINT_TRANSACTION_TIMER_DOC);
conf.define(CAMEL_SOURCE_SMPP_ENDPOINT_ALPHABET_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_SMPP_ENDPOINT_ALPHABET_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SMPP_ENDPOINT_ALPHABET_DOC);
conf.define(CAMEL_SOURCE_SMPP_ENDPOINT_DATA_CODING_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_SMPP_ENDPOINT_DATA_CODING_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SMPP_ENDPOINT_DATA_CODING_DOC);
@@ -235,6 +242,7 @@ public class CamelSmppSourceConnectorConfig
conf.define(CAMEL_SOURCE_SMPP_COMPONENT_PDU_PROCESSOR_DEGREE_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_SMPP_COMPONENT_PDU_PROCESSOR_DEGREE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_SMPP_COMPONENT_PDU_PROCESSOR_DEGREE_DOC);
conf.define(CAMEL_SOURCE_SMPP_COMPONENT_PDU_PROCESSOR_QUEUE_CAPACITY_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_SMPP_COMPONENT_PDU_PROCESSOR_QUEUE_CAPACITY_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_SMPP_COMPONENT_PDU_PROCESSOR_QUEUE_CAPACITY_DOC);
conf.define(CAMEL_SOURCE_SMPP_COMPONENT_SESSION_STATE_LISTENER_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_SMPP_COMPONENT_SESSION_STATE_LISTENER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_SMPP_COMPONENT_SESSION_STATE_LISTENER_DOC);
+ conf.define(CAMEL_SOURCE_SMPP_COMPONENT_SINGLE_DLRCONF,
ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_SMPP_COMPONENT_SINGLE_DLRDEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SMPP_COMPONENT_SINGLE_DLRDOC);
conf.define(CAMEL_SOURCE_SMPP_COMPONENT_TRANSACTION_TIMER_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_SMPP_COMPONENT_TRANSACTION_TIMER_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SMPP_COMPONENT_TRANSACTION_TIMER_DOC);
conf.define(CAMEL_SOURCE_SMPP_COMPONENT_ALPHABET_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_SMPP_COMPONENT_ALPHABET_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SMPP_COMPONENT_ALPHABET_DOC);
conf.define(CAMEL_SOURCE_SMPP_COMPONENT_DATA_CODING_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_SMPP_COMPONENT_DATA_CODING_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SMPP_COMPONENT_DATA_CODING_DOC);
diff --git
a/connectors/camel-smpps-kafka-connector/src/generated/resources/camel-smpps-sink.json
b/connectors/camel-smpps-kafka-connector/src/generated/resources/camel-smpps-sink.json
index abbf4a4..22adb09 100644
---
a/connectors/camel-smpps-kafka-connector/src/generated/resources/camel-smpps-sink.json
+++
b/connectors/camel-smpps-kafka-connector/src/generated/resources/camel-smpps-sink.json
@@ -269,6 +269,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.sink.endpoint.singleDLR": {
+ "name": "camel.sink.endpoint.singleDLR",
+ "description": "When true, the SMSC delivery receipt
would be requested only for the last segment of a multi-segment (long) message.
For short messages, with only 1 segment the behaviour is unchanged.",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.transactionTimer": {
"name": "camel.sink.endpoint.transactionTimer",
"description": "Defines the maximum period of
inactivity allowed after a transaction, after which an SMPP entity may assume
that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME).",
@@ -610,6 +617,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.smpps.singleDLR": {
+ "name": "camel.component.smpps.singleDLR",
+ "description": "When true, the SMSC delivery receipt
would be requested only for the last segment of a multi-segment (long) message.
For short messages, with only 1 segment the behaviour is unchanged.",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.smpps.transactionTimer": {
"name": "camel.component.smpps.transactionTimer",
"description": "Defines the maximum period of
inactivity allowed after a transaction, after which an SMPP entity may assume
that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME).",
diff --git
a/connectors/camel-smpps-kafka-connector/src/generated/resources/camel-smpps-source.json
b/connectors/camel-smpps-kafka-connector/src/generated/resources/camel-smpps-source.json
index f322cc9..c2e23d2 100644
---
a/connectors/camel-smpps-kafka-connector/src/generated/resources/camel-smpps-source.json
+++
b/connectors/camel-smpps-kafka-connector/src/generated/resources/camel-smpps-source.json
@@ -119,6 +119,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.source.endpoint.singleDLR": {
+ "name": "camel.source.endpoint.singleDLR",
+ "description": "When true, the SMSC delivery receipt
would be requested only for the last segment of a multi-segment (long) message.
For short messages, with only 1 segment the behaviour is unchanged.",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.source.endpoint.transactionTimer": {
"name": "camel.source.endpoint.transactionTimer",
"description": "Defines the maximum period of
inactivity allowed after a transaction, after which an SMPP entity may assume
that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME).",
@@ -293,6 +300,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.smpps.singleDLR": {
+ "name": "camel.component.smpps.singleDLR",
+ "description": "When true, the SMSC delivery receipt
would be requested only for the last segment of a multi-segment (long) message.
For short messages, with only 1 segment the behaviour is unchanged.",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.smpps.transactionTimer": {
"name": "camel.component.smpps.transactionTimer",
"description": "Defines the maximum period of
inactivity allowed after a transaction, after which an SMPP entity may assume
that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME).",
diff --git
a/connectors/camel-smpps-kafka-connector/src/main/docs/camel-smpps-kafka-sink-connector.adoc
b/connectors/camel-smpps-kafka-connector/src/main/docs/camel-smpps-kafka-sink-connector.adoc
index cb86b1b..b8f35aa 100644
---
a/connectors/camel-smpps-kafka-connector/src/main/docs/camel-smpps-kafka-sink-connector.adoc
+++
b/connectors/camel-smpps-kafka-connector/src/main/docs/camel-smpps-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.smpps.CamelSmppsSinkConnector
----
-The camel-smpps sink connector supports 76 options, which are listed below.
+The camel-smpps sink connector supports 78 options, which are listed below.
@@ -57,6 +57,7 @@ The camel-smpps sink connector supports 76 options, which are
listed below.
| *camel.sink.endpoint.pduProcessorDegree* | Sets the number of threads which
can read PDU and process them in parallel. | "3" | false | MEDIUM
| *camel.sink.endpoint.pduProcessorQueueCapacity* | Sets the capacity of the
working queue for PDU processing. | "100" | false | MEDIUM
| *camel.sink.endpoint.sessionStateListener* | You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed. | null | false | MEDIUM
+| *camel.sink.endpoint.singleDLR* | When true, the SMSC delivery receipt would
be requested only for the last segment of a multi-segment (long) message. For
short messages, with only 1 segment the behaviour is unchanged. | false | false
| MEDIUM
| *camel.sink.endpoint.transactionTimer* | Defines the maximum period of
inactivity allowed after a transaction, after which an SMPP entity may assume
that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME). | "10000" | false | MEDIUM
| *camel.sink.endpoint.alphabet* | Defines encoding of data according the SMPP
3.4 specification, section 5.2.19. 0: SMSC Default Alphabet 4: 8 bit Alphabet
8: UCS2 Alphabet One of: [0] [4] [8] | null | false | MEDIUM
| *camel.sink.endpoint.dataCoding* | Defines the data coding according the
SMPP 3.4 specification, section 5.2.19. Example data encodings are: 0: SMSC
Default Alphabet 3: Latin 1 (ISO-8859-1) 4: Octet unspecified (8-bit binary) 8:
UCS2 (ISO/IEC-10646) 13: Extended Kanji JIS(X 0212-1990) | null | false | MEDIUM
@@ -95,6 +96,7 @@ The camel-smpps sink connector supports 76 options, which are
listed below.
| *camel.component.smpps.pduProcessorDegree* | Sets the number of threads
which can read PDU and process them in parallel. | "3" | false | MEDIUM
| *camel.component.smpps.pduProcessorQueueCapacity* | Sets the capacity of the
working queue for PDU processing. | "100" | false | MEDIUM
| *camel.component.smpps.sessionStateListener* | You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed. | null | false | MEDIUM
+| *camel.component.smpps.singleDLR* | When true, the SMSC delivery receipt
would be requested only for the last segment of a multi-segment (long) message.
For short messages, with only 1 segment the behaviour is unchanged. | false |
false | MEDIUM
| *camel.component.smpps.transactionTimer* | Defines the maximum period of
inactivity allowed after a transaction, after which an SMPP entity may assume
that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME). | "10000" | false | MEDIUM
| *camel.component.smpps.alphabet* | Defines encoding of data according the
SMPP 3.4 specification, section 5.2.19. 0: SMSC Default Alphabet 4: 8 bit
Alphabet 8: UCS2 Alphabet One of: [0] [4] [8] | null | false | MEDIUM
| *camel.component.smpps.dataCoding* | Defines the data coding according the
SMPP 3.4 specification, section 5.2.19. Example data encodings are: 0: SMSC
Default Alphabet 3: Latin 1 (ISO-8859-1) 4: Octet unspecified (8-bit binary) 8:
UCS2 (ISO/IEC-10646) 13: Extended Kanji JIS(X 0212-1990) | null | false | MEDIUM
diff --git
a/connectors/camel-smpps-kafka-connector/src/main/docs/camel-smpps-kafka-source-connector.adoc
b/connectors/camel-smpps-kafka-connector/src/main/docs/camel-smpps-kafka-source-connector.adoc
index f86cc20..82d2821 100644
---
a/connectors/camel-smpps-kafka-connector/src/main/docs/camel-smpps-kafka-source-connector.adoc
+++
b/connectors/camel-smpps-kafka-connector/src/main/docs/camel-smpps-kafka-source-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.smpps.CamelSmppsSourceConnector
----
-The camel-smpps source connector supports 52 options, which are listed below.
+The camel-smpps source connector supports 54 options, which are listed below.
@@ -46,6 +46,7 @@ The camel-smpps source connector supports 52 options, which
are listed below.
| *camel.source.endpoint.pduProcessorDegree* | Sets the number of threads
which can read PDU and process them in parallel. | "3" | false | MEDIUM
| *camel.source.endpoint.pduProcessorQueueCapacity* | Sets the capacity of the
working queue for PDU processing. | "100" | false | MEDIUM
| *camel.source.endpoint.sessionStateListener* | You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed. | null | false | MEDIUM
+| *camel.source.endpoint.singleDLR* | When true, the SMSC delivery receipt
would be requested only for the last segment of a multi-segment (long) message.
For short messages, with only 1 segment the behaviour is unchanged. | false |
false | MEDIUM
| *camel.source.endpoint.transactionTimer* | Defines the maximum period of
inactivity allowed after a transaction, after which an SMPP entity may assume
that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME). | "10000" | false | MEDIUM
| *camel.source.endpoint.alphabet* | Defines encoding of data according the
SMPP 3.4 specification, section 5.2.19. 0: SMSC Default Alphabet 4: 8 bit
Alphabet 8: UCS2 Alphabet One of: [0] [4] [8] | null | false | MEDIUM
| *camel.source.endpoint.dataCoding* | Defines the data coding according the
SMPP 3.4 specification, section 5.2.19. Example data encodings are: 0: SMSC
Default Alphabet 3: Latin 1 (ISO-8859-1) 4: Octet unspecified (8-bit binary) 8:
UCS2 (ISO/IEC-10646) 13: Extended Kanji JIS(X 0212-1990) | null | false | MEDIUM
@@ -71,6 +72,7 @@ The camel-smpps source connector supports 52 options, which
are listed below.
| *camel.component.smpps.pduProcessorDegree* | Sets the number of threads
which can read PDU and process them in parallel. | "3" | false | MEDIUM
| *camel.component.smpps.pduProcessorQueueCapacity* | Sets the capacity of the
working queue for PDU processing. | "100" | false | MEDIUM
| *camel.component.smpps.sessionStateListener* | You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed. | null | false | MEDIUM
+| *camel.component.smpps.singleDLR* | When true, the SMSC delivery receipt
would be requested only for the last segment of a multi-segment (long) message.
For short messages, with only 1 segment the behaviour is unchanged. | false |
false | MEDIUM
| *camel.component.smpps.transactionTimer* | Defines the maximum period of
inactivity allowed after a transaction, after which an SMPP entity may assume
that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME). | "10000" | false | MEDIUM
| *camel.component.smpps.alphabet* | Defines encoding of data according the
SMPP 3.4 specification, section 5.2.19. 0: SMSC Default Alphabet 4: 8 bit
Alphabet 8: UCS2 Alphabet One of: [0] [4] [8] | null | false | MEDIUM
| *camel.component.smpps.dataCoding* | Defines the data coding according the
SMPP 3.4 specification, section 5.2.19. Example data encodings are: 0: SMSC
Default Alphabet 3: Latin 1 (ISO-8859-1) 4: Octet unspecified (8-bit binary) 8:
UCS2 (ISO/IEC-10646) 13: Extended Kanji JIS(X 0212-1990) | null | false | MEDIUM
diff --git
a/connectors/camel-smpps-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/smpps/CamelSmppsSinkConnectorConfig.java
b/connectors/camel-smpps-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/smpps/CamelSmppsSinkConnectorConfig.java
index 8beef58..dc04af0 100644
---
a/connectors/camel-smpps-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/smpps/CamelSmppsSinkConnectorConfig.java
+++
b/connectors/camel-smpps-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/smpps/CamelSmppsSinkConnectorConfig.java
@@ -102,6 +102,9 @@ public class CamelSmppsSinkConnectorConfig extends
CamelSinkConnectorConfig {
public static final String
CAMEL_SINK_SMPPS_ENDPOINT_SESSION_STATE_LISTENER_CONF =
"camel.sink.endpoint.sessionStateListener";
public static final String
CAMEL_SINK_SMPPS_ENDPOINT_SESSION_STATE_LISTENER_DOC = "You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed.";
public static final String
CAMEL_SINK_SMPPS_ENDPOINT_SESSION_STATE_LISTENER_DEFAULT = null;
+ public static final String CAMEL_SINK_SMPPS_ENDPOINT_SINGLE_DLRCONF =
"camel.sink.endpoint.singleDLR";
+ public static final String CAMEL_SINK_SMPPS_ENDPOINT_SINGLE_DLRDOC = "When
true, the SMSC delivery receipt would be requested only for the last segment of
a multi-segment (long) message. For short messages, with only 1 segment the
behaviour is unchanged.";
+ public static final Boolean CAMEL_SINK_SMPPS_ENDPOINT_SINGLE_DLRDEFAULT =
false;
public static final String
CAMEL_SINK_SMPPS_ENDPOINT_TRANSACTION_TIMER_CONF =
"camel.sink.endpoint.transactionTimer";
public static final String CAMEL_SINK_SMPPS_ENDPOINT_TRANSACTION_TIMER_DOC
= "Defines the maximum period of inactivity allowed after a transaction, after
which an SMPP entity may assume that the session is no longer active. This
timer may be active on either communicating SMPP entity (i.e. SMSC or ESME).";
public static final String
CAMEL_SINK_SMPPS_ENDPOINT_TRANSACTION_TIMER_DEFAULT = "10000";
@@ -216,6 +219,9 @@ public class CamelSmppsSinkConnectorConfig extends
CamelSinkConnectorConfig {
public static final String
CAMEL_SINK_SMPPS_COMPONENT_SESSION_STATE_LISTENER_CONF =
"camel.component.smpps.sessionStateListener";
public static final String
CAMEL_SINK_SMPPS_COMPONENT_SESSION_STATE_LISTENER_DOC = "You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed.";
public static final String
CAMEL_SINK_SMPPS_COMPONENT_SESSION_STATE_LISTENER_DEFAULT = null;
+ public static final String CAMEL_SINK_SMPPS_COMPONENT_SINGLE_DLRCONF =
"camel.component.smpps.singleDLR";
+ public static final String CAMEL_SINK_SMPPS_COMPONENT_SINGLE_DLRDOC =
"When true, the SMSC delivery receipt would be requested only for the last
segment of a multi-segment (long) message. For short messages, with only 1
segment the behaviour is unchanged.";
+ public static final Boolean CAMEL_SINK_SMPPS_COMPONENT_SINGLE_DLRDEFAULT =
false;
public static final String
CAMEL_SINK_SMPPS_COMPONENT_TRANSACTION_TIMER_CONF =
"camel.component.smpps.transactionTimer";
public static final String
CAMEL_SINK_SMPPS_COMPONENT_TRANSACTION_TIMER_DOC = "Defines the maximum period
of inactivity allowed after a transaction, after which an SMPP entity may
assume that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME).";
public static final String
CAMEL_SINK_SMPPS_COMPONENT_TRANSACTION_TIMER_DEFAULT = "10000";
@@ -291,6 +297,7 @@ public class CamelSmppsSinkConnectorConfig extends
CamelSinkConnectorConfig {
conf.define(CAMEL_SINK_SMPPS_ENDPOINT_PDU_PROCESSOR_DEGREE_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SMPPS_ENDPOINT_PDU_PROCESSOR_DEGREE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_SMPPS_ENDPOINT_PDU_PROCESSOR_DEGREE_DOC);
conf.define(CAMEL_SINK_SMPPS_ENDPOINT_PDU_PROCESSOR_QUEUE_CAPACITY_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_SMPPS_ENDPOINT_PDU_PROCESSOR_QUEUE_CAPACITY_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_SMPPS_ENDPOINT_PDU_PROCESSOR_QUEUE_CAPACITY_DOC);
conf.define(CAMEL_SINK_SMPPS_ENDPOINT_SESSION_STATE_LISTENER_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_SMPPS_ENDPOINT_SESSION_STATE_LISTENER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_SMPPS_ENDPOINT_SESSION_STATE_LISTENER_DOC);
+ conf.define(CAMEL_SINK_SMPPS_ENDPOINT_SINGLE_DLRCONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_SMPPS_ENDPOINT_SINGLE_DLRDEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SMPPS_ENDPOINT_SINGLE_DLRDOC);
conf.define(CAMEL_SINK_SMPPS_ENDPOINT_TRANSACTION_TIMER_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SMPPS_ENDPOINT_TRANSACTION_TIMER_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SMPPS_ENDPOINT_TRANSACTION_TIMER_DOC);
conf.define(CAMEL_SINK_SMPPS_ENDPOINT_ALPHABET_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SMPPS_ENDPOINT_ALPHABET_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SMPPS_ENDPOINT_ALPHABET_DOC);
conf.define(CAMEL_SINK_SMPPS_ENDPOINT_DATA_CODING_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SMPPS_ENDPOINT_DATA_CODING_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SMPPS_ENDPOINT_DATA_CODING_DOC);
@@ -329,6 +336,7 @@ public class CamelSmppsSinkConnectorConfig extends
CamelSinkConnectorConfig {
conf.define(CAMEL_SINK_SMPPS_COMPONENT_PDU_PROCESSOR_DEGREE_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SMPPS_COMPONENT_PDU_PROCESSOR_DEGREE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_SMPPS_COMPONENT_PDU_PROCESSOR_DEGREE_DOC);
conf.define(CAMEL_SINK_SMPPS_COMPONENT_PDU_PROCESSOR_QUEUE_CAPACITY_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_SMPPS_COMPONENT_PDU_PROCESSOR_QUEUE_CAPACITY_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_SMPPS_COMPONENT_PDU_PROCESSOR_QUEUE_CAPACITY_DOC);
conf.define(CAMEL_SINK_SMPPS_COMPONENT_SESSION_STATE_LISTENER_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_SMPPS_COMPONENT_SESSION_STATE_LISTENER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_SMPPS_COMPONENT_SESSION_STATE_LISTENER_DOC);
+ conf.define(CAMEL_SINK_SMPPS_COMPONENT_SINGLE_DLRCONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_SMPPS_COMPONENT_SINGLE_DLRDEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SMPPS_COMPONENT_SINGLE_DLRDOC);
conf.define(CAMEL_SINK_SMPPS_COMPONENT_TRANSACTION_TIMER_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SMPPS_COMPONENT_TRANSACTION_TIMER_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SMPPS_COMPONENT_TRANSACTION_TIMER_DOC);
conf.define(CAMEL_SINK_SMPPS_COMPONENT_ALPHABET_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SMPPS_COMPONENT_ALPHABET_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SMPPS_COMPONENT_ALPHABET_DOC);
conf.define(CAMEL_SINK_SMPPS_COMPONENT_DATA_CODING_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SMPPS_COMPONENT_DATA_CODING_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SMPPS_COMPONENT_DATA_CODING_DOC);
diff --git
a/connectors/camel-smpps-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/smpps/CamelSmppsSourceConnectorConfig.java
b/connectors/camel-smpps-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/smpps/CamelSmppsSourceConnectorConfig.java
index 26d9181..66533b2 100644
---
a/connectors/camel-smpps-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/smpps/CamelSmppsSourceConnectorConfig.java
+++
b/connectors/camel-smpps-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/smpps/CamelSmppsSourceConnectorConfig.java
@@ -71,6 +71,9 @@ public class CamelSmppsSourceConnectorConfig
public static final String
CAMEL_SOURCE_SMPPS_ENDPOINT_SESSION_STATE_LISTENER_CONF =
"camel.source.endpoint.sessionStateListener";
public static final String
CAMEL_SOURCE_SMPPS_ENDPOINT_SESSION_STATE_LISTENER_DOC = "You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed.";
public static final String
CAMEL_SOURCE_SMPPS_ENDPOINT_SESSION_STATE_LISTENER_DEFAULT = null;
+ public static final String CAMEL_SOURCE_SMPPS_ENDPOINT_SINGLE_DLRCONF =
"camel.source.endpoint.singleDLR";
+ public static final String CAMEL_SOURCE_SMPPS_ENDPOINT_SINGLE_DLRDOC =
"When true, the SMSC delivery receipt would be requested only for the last
segment of a multi-segment (long) message. For short messages, with only 1
segment the behaviour is unchanged.";
+ public static final Boolean CAMEL_SOURCE_SMPPS_ENDPOINT_SINGLE_DLRDEFAULT
= false;
public static final String
CAMEL_SOURCE_SMPPS_ENDPOINT_TRANSACTION_TIMER_CONF =
"camel.source.endpoint.transactionTimer";
public static final String
CAMEL_SOURCE_SMPPS_ENDPOINT_TRANSACTION_TIMER_DOC = "Defines the maximum period
of inactivity allowed after a transaction, after which an SMPP entity may
assume that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME).";
public static final String
CAMEL_SOURCE_SMPPS_ENDPOINT_TRANSACTION_TIMER_DEFAULT = "10000";
@@ -146,6 +149,9 @@ public class CamelSmppsSourceConnectorConfig
public static final String
CAMEL_SOURCE_SMPPS_COMPONENT_SESSION_STATE_LISTENER_CONF =
"camel.component.smpps.sessionStateListener";
public static final String
CAMEL_SOURCE_SMPPS_COMPONENT_SESSION_STATE_LISTENER_DOC = "You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed.";
public static final String
CAMEL_SOURCE_SMPPS_COMPONENT_SESSION_STATE_LISTENER_DEFAULT = null;
+ public static final String CAMEL_SOURCE_SMPPS_COMPONENT_SINGLE_DLRCONF =
"camel.component.smpps.singleDLR";
+ public static final String CAMEL_SOURCE_SMPPS_COMPONENT_SINGLE_DLRDOC =
"When true, the SMSC delivery receipt would be requested only for the last
segment of a multi-segment (long) message. For short messages, with only 1
segment the behaviour is unchanged.";
+ public static final Boolean CAMEL_SOURCE_SMPPS_COMPONENT_SINGLE_DLRDEFAULT
= false;
public static final String
CAMEL_SOURCE_SMPPS_COMPONENT_TRANSACTION_TIMER_CONF =
"camel.component.smpps.transactionTimer";
public static final String
CAMEL_SOURCE_SMPPS_COMPONENT_TRANSACTION_TIMER_DOC = "Defines the maximum
period of inactivity allowed after a transaction, after which an SMPP entity
may assume that the session is no longer active. This timer may be active on
either communicating SMPP entity (i.e. SMSC or ESME).";
public static final String
CAMEL_SOURCE_SMPPS_COMPONENT_TRANSACTION_TIMER_DEFAULT = "10000";
@@ -210,6 +216,7 @@ public class CamelSmppsSourceConnectorConfig
conf.define(CAMEL_SOURCE_SMPPS_ENDPOINT_PDU_PROCESSOR_DEGREE_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_SMPPS_ENDPOINT_PDU_PROCESSOR_DEGREE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_SMPPS_ENDPOINT_PDU_PROCESSOR_DEGREE_DOC);
conf.define(CAMEL_SOURCE_SMPPS_ENDPOINT_PDU_PROCESSOR_QUEUE_CAPACITY_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_SMPPS_ENDPOINT_PDU_PROCESSOR_QUEUE_CAPACITY_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_SMPPS_ENDPOINT_PDU_PROCESSOR_QUEUE_CAPACITY_DOC);
conf.define(CAMEL_SOURCE_SMPPS_ENDPOINT_SESSION_STATE_LISTENER_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_SMPPS_ENDPOINT_SESSION_STATE_LISTENER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_SMPPS_ENDPOINT_SESSION_STATE_LISTENER_DOC);
+ conf.define(CAMEL_SOURCE_SMPPS_ENDPOINT_SINGLE_DLRCONF,
ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_SMPPS_ENDPOINT_SINGLE_DLRDEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SMPPS_ENDPOINT_SINGLE_DLRDOC);
conf.define(CAMEL_SOURCE_SMPPS_ENDPOINT_TRANSACTION_TIMER_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_SMPPS_ENDPOINT_TRANSACTION_TIMER_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SMPPS_ENDPOINT_TRANSACTION_TIMER_DOC);
conf.define(CAMEL_SOURCE_SMPPS_ENDPOINT_ALPHABET_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_SMPPS_ENDPOINT_ALPHABET_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SMPPS_ENDPOINT_ALPHABET_DOC);
conf.define(CAMEL_SOURCE_SMPPS_ENDPOINT_DATA_CODING_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_SMPPS_ENDPOINT_DATA_CODING_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SMPPS_ENDPOINT_DATA_CODING_DOC);
@@ -235,6 +242,7 @@ public class CamelSmppsSourceConnectorConfig
conf.define(CAMEL_SOURCE_SMPPS_COMPONENT_PDU_PROCESSOR_DEGREE_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_SMPPS_COMPONENT_PDU_PROCESSOR_DEGREE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_SMPPS_COMPONENT_PDU_PROCESSOR_DEGREE_DOC);
conf.define(CAMEL_SOURCE_SMPPS_COMPONENT_PDU_PROCESSOR_QUEUE_CAPACITY_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_SMPPS_COMPONENT_PDU_PROCESSOR_QUEUE_CAPACITY_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_SMPPS_COMPONENT_PDU_PROCESSOR_QUEUE_CAPACITY_DOC);
conf.define(CAMEL_SOURCE_SMPPS_COMPONENT_SESSION_STATE_LISTENER_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_SMPPS_COMPONENT_SESSION_STATE_LISTENER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_SMPPS_COMPONENT_SESSION_STATE_LISTENER_DOC);
+ conf.define(CAMEL_SOURCE_SMPPS_COMPONENT_SINGLE_DLRCONF,
ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_SMPPS_COMPONENT_SINGLE_DLRDEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SMPPS_COMPONENT_SINGLE_DLRDOC);
conf.define(CAMEL_SOURCE_SMPPS_COMPONENT_TRANSACTION_TIMER_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_SMPPS_COMPONENT_TRANSACTION_TIMER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_SMPPS_COMPONENT_TRANSACTION_TIMER_DOC);
conf.define(CAMEL_SOURCE_SMPPS_COMPONENT_ALPHABET_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_SMPPS_COMPONENT_ALPHABET_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SMPPS_COMPONENT_ALPHABET_DOC);
conf.define(CAMEL_SOURCE_SMPPS_COMPONENT_DATA_CODING_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_SMPPS_COMPONENT_DATA_CODING_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SMPPS_COMPONENT_DATA_CODING_DOC);
diff --git
a/docs/modules/ROOT/pages/connectors/camel-pubnub-kafka-sink-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-pubnub-kafka-sink-connector.adoc
index e5cdebb..c31a762 100644
--- a/docs/modules/ROOT/pages/connectors/camel-pubnub-kafka-sink-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-pubnub-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.pubnub.CamelPubnubSinkConnector
----
-The camel-pubnub sink connector supports 13 options, which are listed below.
+The camel-pubnub sink connector supports 22 options, which are listed below.
@@ -42,8 +42,17 @@ The camel-pubnub sink connector supports 13 options, which
are listed below.
| *camel.sink.endpoint.secretKey* | The secret key used for message signing. |
null | false | MEDIUM
| *camel.sink.endpoint.secure* | Use SSL for secure transmission. | true |
false | MEDIUM
| *camel.sink.endpoint.subscribeKey* | The subscribe key obtained from your
PubNub account. Required when subscribing to channels or listening for presence
events | null | false | MEDIUM
+| *camel.component.pubnub.configuration* | The component configurations | null
| false | MEDIUM
+| *camel.component.pubnub.uuid* | UUID to be used as a device identifier, a
default UUID is generated if not passed. | null | false | MEDIUM
| *camel.component.pubnub.lazyStartProducer* | Whether the producer should be
started lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a producer may otherwise
fail during starting and cause the route to fail being started. By deferring
this startup to be lazy then the startup failure can be handled during routing
messages via Camel's routing error handlers. Beware that when the first message
is processed then [...]
+| *camel.component.pubnub.operation* | The operation to perform. PUBLISH:
Default. Send a message to all subscribers of a channel. FIRE: allows the
client to send a message to BLOCKS Event Handlers. These messages will go
directly to any Event Handlers registered on the channel. HERENOW: Obtain
information about the current state of a channel including a list of unique
user-ids currently subscribed to the channel and the total occupancy count.
WHERENOW: Obtain information about the curre [...]
| *camel.component.pubnub.autowiredEnabled* | Whether autowiring is enabled.
This is used for automatic autowiring options (the option must be marked as
autowired) by looking up in the registry to find if there is a single instance
of matching type, which then gets configured on the component. This can be used
for automatic configuring JDBC data sources, JMS connection factories, AWS
Clients, etc. | true | false | MEDIUM
+| *camel.component.pubnub.authKey* | If Access Manager is utilized, client
will use this authKey in all restricted requests. | null | false | MEDIUM
+| *camel.component.pubnub.cipherKey* | If cipher is passed, all communications
to/from PubNub will be encrypted. | null | false | MEDIUM
+| *camel.component.pubnub.publishKey* | The publish key obtained from your
PubNub account. Required when publishing messages. | null | false | MEDIUM
+| *camel.component.pubnub.secretKey* | The secret key used for message
signing. | null | false | MEDIUM
+| *camel.component.pubnub.secure* | Use SSL for secure transmission. | true |
false | MEDIUM
+| *camel.component.pubnub.subscribeKey* | The subscribe key obtained from your
PubNub account. Required when subscribing to channels or listening for presence
events | null | false | MEDIUM
|===
@@ -61,8 +70,4 @@ The camel-pubnub sink connector has no transforms out of the
box.
The camel-pubnub sink connector has no aggregation strategies out of the box.
-
-
-
-
// kafka-connector options: END
diff --git
a/docs/modules/ROOT/pages/connectors/camel-pubnub-kafka-source-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-pubnub-kafka-source-connector.adoc
index dee1105..4c85e6b 100644
---
a/docs/modules/ROOT/pages/connectors/camel-pubnub-kafka-source-connector.adoc
+++
b/docs/modules/ROOT/pages/connectors/camel-pubnub-kafka-source-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.pubnub.CamelPubnubSourceConnecto
----
-The camel-pubnub source connector supports 15 options, which are listed below.
+The camel-pubnub source connector supports 24 options, which are listed below.
@@ -44,8 +44,17 @@ The camel-pubnub source connector supports 15 options, which
are listed below.
| *camel.source.endpoint.secretKey* | The secret key used for message signing.
| null | false | MEDIUM
| *camel.source.endpoint.secure* | Use SSL for secure transmission. | true |
false | MEDIUM
| *camel.source.endpoint.subscribeKey* | The subscribe key obtained from your
PubNub account. Required when subscribing to channels or listening for presence
events | null | false | MEDIUM
+| *camel.component.pubnub.configuration* | The component configurations | null
| false | MEDIUM
+| *camel.component.pubnub.uuid* | UUID to be used as a device identifier, a
default UUID is generated if not passed. | null | false | MEDIUM
| *camel.component.pubnub.bridgeErrorHandler* | Allows for bridging the
consumer to the Camel routing Error Handler, which mean any exceptions occurred
while the consumer is trying to pickup incoming messages, or the likes, will
now be processed as a message and handled by the routing Error Handler. By
default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal
with exceptions, that will be logged at WARN or ERROR level and ignored. |
false | false | MEDIUM
+| *camel.component.pubnub.withPresence* | Also subscribe to related presence
information | false | false | MEDIUM
| *camel.component.pubnub.autowiredEnabled* | Whether autowiring is enabled.
This is used for automatic autowiring options (the option must be marked as
autowired) by looking up in the registry to find if there is a single instance
of matching type, which then gets configured on the component. This can be used
for automatic configuring JDBC data sources, JMS connection factories, AWS
Clients, etc. | true | false | MEDIUM
+| *camel.component.pubnub.authKey* | If Access Manager is utilized, client
will use this authKey in all restricted requests. | null | false | MEDIUM
+| *camel.component.pubnub.cipherKey* | If cipher is passed, all communications
to/from PubNub will be encrypted. | null | false | MEDIUM
+| *camel.component.pubnub.publishKey* | The publish key obtained from your
PubNub account. Required when publishing messages. | null | false | MEDIUM
+| *camel.component.pubnub.secretKey* | The secret key used for message
signing. | null | false | MEDIUM
+| *camel.component.pubnub.secure* | Use SSL for secure transmission. | true |
false | MEDIUM
+| *camel.component.pubnub.subscribeKey* | The subscribe key obtained from your
PubNub account. Required when subscribing to channels or listening for presence
events | null | false | MEDIUM
|===
@@ -63,8 +72,4 @@ The camel-pubnub source connector has no transforms out of
the box.
The camel-pubnub source connector has no aggregation strategies out of the box.
-
-
-
-
// kafka-connector options: END
diff --git
a/docs/modules/ROOT/pages/connectors/camel-smpp-kafka-sink-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-smpp-kafka-sink-connector.adoc
index 1e54945..c89810d 100644
--- a/docs/modules/ROOT/pages/connectors/camel-smpp-kafka-sink-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-smpp-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.smpp.CamelSmppSinkConnector
----
-The camel-smpp sink connector supports 76 options, which are listed below.
+The camel-smpp sink connector supports 78 options, which are listed below.
@@ -57,6 +57,7 @@ The camel-smpp sink connector supports 76 options, which are
listed below.
| *camel.sink.endpoint.pduProcessorDegree* | Sets the number of threads which
can read PDU and process them in parallel. | "3" | false | MEDIUM
| *camel.sink.endpoint.pduProcessorQueueCapacity* | Sets the capacity of the
working queue for PDU processing. | "100" | false | MEDIUM
| *camel.sink.endpoint.sessionStateListener* | You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed. | null | false | MEDIUM
+| *camel.sink.endpoint.singleDLR* | When true, the SMSC delivery receipt would
be requested only for the last segment of a multi-segment (long) message. For
short messages, with only 1 segment the behaviour is unchanged. | false | false
| MEDIUM
| *camel.sink.endpoint.transactionTimer* | Defines the maximum period of
inactivity allowed after a transaction, after which an SMPP entity may assume
that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME). | "10000" | false | MEDIUM
| *camel.sink.endpoint.alphabet* | Defines encoding of data according the SMPP
3.4 specification, section 5.2.19. 0: SMSC Default Alphabet 4: 8 bit Alphabet
8: UCS2 Alphabet One of: [0] [4] [8] | null | false | MEDIUM
| *camel.sink.endpoint.dataCoding* | Defines the data coding according the
SMPP 3.4 specification, section 5.2.19. Example data encodings are: 0: SMSC
Default Alphabet 3: Latin 1 (ISO-8859-1) 4: Octet unspecified (8-bit binary) 8:
UCS2 (ISO/IEC-10646) 13: Extended Kanji JIS(X 0212-1990) | null | false | MEDIUM
@@ -95,6 +96,7 @@ The camel-smpp sink connector supports 76 options, which are
listed below.
| *camel.component.smpp.pduProcessorDegree* | Sets the number of threads which
can read PDU and process them in parallel. | "3" | false | MEDIUM
| *camel.component.smpp.pduProcessorQueueCapacity* | Sets the capacity of the
working queue for PDU processing. | "100" | false | MEDIUM
| *camel.component.smpp.sessionStateListener* | You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed. | null | false | MEDIUM
+| *camel.component.smpp.singleDLR* | When true, the SMSC delivery receipt
would be requested only for the last segment of a multi-segment (long) message.
For short messages, with only 1 segment the behaviour is unchanged. | false |
false | MEDIUM
| *camel.component.smpp.transactionTimer* | Defines the maximum period of
inactivity allowed after a transaction, after which an SMPP entity may assume
that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME). | "10000" | false | MEDIUM
| *camel.component.smpp.alphabet* | Defines encoding of data according the
SMPP 3.4 specification, section 5.2.19. 0: SMSC Default Alphabet 4: 8 bit
Alphabet 8: UCS2 Alphabet One of: [0] [4] [8] | null | false | MEDIUM
| *camel.component.smpp.dataCoding* | Defines the data coding according the
SMPP 3.4 specification, section 5.2.19. Example data encodings are: 0: SMSC
Default Alphabet 3: Latin 1 (ISO-8859-1) 4: Octet unspecified (8-bit binary) 8:
UCS2 (ISO/IEC-10646) 13: Extended Kanji JIS(X 0212-1990) | null | false | MEDIUM
@@ -124,8 +126,4 @@ The camel-smpp sink connector has no transforms out of the
box.
The camel-smpp sink connector has no aggregation strategies out of the box.
-
-
-
-
// kafka-connector options: END
diff --git
a/docs/modules/ROOT/pages/connectors/camel-smpp-kafka-source-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-smpp-kafka-source-connector.adoc
index 1a0883b..63349de 100644
--- a/docs/modules/ROOT/pages/connectors/camel-smpp-kafka-source-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-smpp-kafka-source-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.smpp.CamelSmppSourceConnector
----
-The camel-smpp source connector supports 52 options, which are listed below.
+The camel-smpp source connector supports 54 options, which are listed below.
@@ -46,6 +46,7 @@ The camel-smpp source connector supports 52 options, which
are listed below.
| *camel.source.endpoint.pduProcessorDegree* | Sets the number of threads
which can read PDU and process them in parallel. | "3" | false | MEDIUM
| *camel.source.endpoint.pduProcessorQueueCapacity* | Sets the capacity of the
working queue for PDU processing. | "100" | false | MEDIUM
| *camel.source.endpoint.sessionStateListener* | You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed. | null | false | MEDIUM
+| *camel.source.endpoint.singleDLR* | When true, the SMSC delivery receipt
would be requested only for the last segment of a multi-segment (long) message.
For short messages, with only 1 segment the behaviour is unchanged. | false |
false | MEDIUM
| *camel.source.endpoint.transactionTimer* | Defines the maximum period of
inactivity allowed after a transaction, after which an SMPP entity may assume
that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME). | "10000" | false | MEDIUM
| *camel.source.endpoint.alphabet* | Defines encoding of data according the
SMPP 3.4 specification, section 5.2.19. 0: SMSC Default Alphabet 4: 8 bit
Alphabet 8: UCS2 Alphabet One of: [0] [4] [8] | null | false | MEDIUM
| *camel.source.endpoint.dataCoding* | Defines the data coding according the
SMPP 3.4 specification, section 5.2.19. Example data encodings are: 0: SMSC
Default Alphabet 3: Latin 1 (ISO-8859-1) 4: Octet unspecified (8-bit binary) 8:
UCS2 (ISO/IEC-10646) 13: Extended Kanji JIS(X 0212-1990) | null | false | MEDIUM
@@ -71,6 +72,7 @@ The camel-smpp source connector supports 52 options, which
are listed below.
| *camel.component.smpp.pduProcessorDegree* | Sets the number of threads which
can read PDU and process them in parallel. | "3" | false | MEDIUM
| *camel.component.smpp.pduProcessorQueueCapacity* | Sets the capacity of the
working queue for PDU processing. | "100" | false | MEDIUM
| *camel.component.smpp.sessionStateListener* | You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed. | null | false | MEDIUM
+| *camel.component.smpp.singleDLR* | When true, the SMSC delivery receipt
would be requested only for the last segment of a multi-segment (long) message.
For short messages, with only 1 segment the behaviour is unchanged. | false |
false | MEDIUM
| *camel.component.smpp.transactionTimer* | Defines the maximum period of
inactivity allowed after a transaction, after which an SMPP entity may assume
that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME). | "10000" | false | MEDIUM
| *camel.component.smpp.alphabet* | Defines encoding of data according the
SMPP 3.4 specification, section 5.2.19. 0: SMSC Default Alphabet 4: 8 bit
Alphabet 8: UCS2 Alphabet One of: [0] [4] [8] | null | false | MEDIUM
| *camel.component.smpp.dataCoding* | Defines the data coding according the
SMPP 3.4 specification, section 5.2.19. Example data encodings are: 0: SMSC
Default Alphabet 3: Latin 1 (ISO-8859-1) 4: Octet unspecified (8-bit binary) 8:
UCS2 (ISO/IEC-10646) 13: Extended Kanji JIS(X 0212-1990) | null | false | MEDIUM
@@ -100,8 +102,4 @@ The camel-smpp source connector has no transforms out of
the box.
The camel-smpp source connector has no aggregation strategies out of the box.
-
-
-
-
// kafka-connector options: END
diff --git
a/docs/modules/ROOT/pages/connectors/camel-smpps-kafka-sink-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-smpps-kafka-sink-connector.adoc
index ed9458c..b8f35aa 100644
--- a/docs/modules/ROOT/pages/connectors/camel-smpps-kafka-sink-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-smpps-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.smpps.CamelSmppsSinkConnector
----
-The camel-smpps sink connector supports 76 options, which are listed below.
+The camel-smpps sink connector supports 78 options, which are listed below.
@@ -57,6 +57,7 @@ The camel-smpps sink connector supports 76 options, which are
listed below.
| *camel.sink.endpoint.pduProcessorDegree* | Sets the number of threads which
can read PDU and process them in parallel. | "3" | false | MEDIUM
| *camel.sink.endpoint.pduProcessorQueueCapacity* | Sets the capacity of the
working queue for PDU processing. | "100" | false | MEDIUM
| *camel.sink.endpoint.sessionStateListener* | You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed. | null | false | MEDIUM
+| *camel.sink.endpoint.singleDLR* | When true, the SMSC delivery receipt would
be requested only for the last segment of a multi-segment (long) message. For
short messages, with only 1 segment the behaviour is unchanged. | false | false
| MEDIUM
| *camel.sink.endpoint.transactionTimer* | Defines the maximum period of
inactivity allowed after a transaction, after which an SMPP entity may assume
that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME). | "10000" | false | MEDIUM
| *camel.sink.endpoint.alphabet* | Defines encoding of data according the SMPP
3.4 specification, section 5.2.19. 0: SMSC Default Alphabet 4: 8 bit Alphabet
8: UCS2 Alphabet One of: [0] [4] [8] | null | false | MEDIUM
| *camel.sink.endpoint.dataCoding* | Defines the data coding according the
SMPP 3.4 specification, section 5.2.19. Example data encodings are: 0: SMSC
Default Alphabet 3: Latin 1 (ISO-8859-1) 4: Octet unspecified (8-bit binary) 8:
UCS2 (ISO/IEC-10646) 13: Extended Kanji JIS(X 0212-1990) | null | false | MEDIUM
@@ -95,6 +96,7 @@ The camel-smpps sink connector supports 76 options, which are
listed below.
| *camel.component.smpps.pduProcessorDegree* | Sets the number of threads
which can read PDU and process them in parallel. | "3" | false | MEDIUM
| *camel.component.smpps.pduProcessorQueueCapacity* | Sets the capacity of the
working queue for PDU processing. | "100" | false | MEDIUM
| *camel.component.smpps.sessionStateListener* | You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed. | null | false | MEDIUM
+| *camel.component.smpps.singleDLR* | When true, the SMSC delivery receipt
would be requested only for the last segment of a multi-segment (long) message.
For short messages, with only 1 segment the behaviour is unchanged. | false |
false | MEDIUM
| *camel.component.smpps.transactionTimer* | Defines the maximum period of
inactivity allowed after a transaction, after which an SMPP entity may assume
that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME). | "10000" | false | MEDIUM
| *camel.component.smpps.alphabet* | Defines encoding of data according the
SMPP 3.4 specification, section 5.2.19. 0: SMSC Default Alphabet 4: 8 bit
Alphabet 8: UCS2 Alphabet One of: [0] [4] [8] | null | false | MEDIUM
| *camel.component.smpps.dataCoding* | Defines the data coding according the
SMPP 3.4 specification, section 5.2.19. Example data encodings are: 0: SMSC
Default Alphabet 3: Latin 1 (ISO-8859-1) 4: Octet unspecified (8-bit binary) 8:
UCS2 (ISO/IEC-10646) 13: Extended Kanji JIS(X 0212-1990) | null | false | MEDIUM
@@ -124,8 +126,4 @@ The camel-smpps sink connector has no transforms out of the
box.
The camel-smpps sink connector has no aggregation strategies out of the box.
-
-
-
-
// kafka-connector options: END
diff --git
a/docs/modules/ROOT/pages/connectors/camel-smpps-kafka-source-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-smpps-kafka-source-connector.adoc
index 2331e27..82d2821 100644
--- a/docs/modules/ROOT/pages/connectors/camel-smpps-kafka-source-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-smpps-kafka-source-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.smpps.CamelSmppsSourceConnector
----
-The camel-smpps source connector supports 52 options, which are listed below.
+The camel-smpps source connector supports 54 options, which are listed below.
@@ -46,6 +46,7 @@ The camel-smpps source connector supports 52 options, which
are listed below.
| *camel.source.endpoint.pduProcessorDegree* | Sets the number of threads
which can read PDU and process them in parallel. | "3" | false | MEDIUM
| *camel.source.endpoint.pduProcessorQueueCapacity* | Sets the capacity of the
working queue for PDU processing. | "100" | false | MEDIUM
| *camel.source.endpoint.sessionStateListener* | You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed. | null | false | MEDIUM
+| *camel.source.endpoint.singleDLR* | When true, the SMSC delivery receipt
would be requested only for the last segment of a multi-segment (long) message.
For short messages, with only 1 segment the behaviour is unchanged. | false |
false | MEDIUM
| *camel.source.endpoint.transactionTimer* | Defines the maximum period of
inactivity allowed after a transaction, after which an SMPP entity may assume
that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME). | "10000" | false | MEDIUM
| *camel.source.endpoint.alphabet* | Defines encoding of data according the
SMPP 3.4 specification, section 5.2.19. 0: SMSC Default Alphabet 4: 8 bit
Alphabet 8: UCS2 Alphabet One of: [0] [4] [8] | null | false | MEDIUM
| *camel.source.endpoint.dataCoding* | Defines the data coding according the
SMPP 3.4 specification, section 5.2.19. Example data encodings are: 0: SMSC
Default Alphabet 3: Latin 1 (ISO-8859-1) 4: Octet unspecified (8-bit binary) 8:
UCS2 (ISO/IEC-10646) 13: Extended Kanji JIS(X 0212-1990) | null | false | MEDIUM
@@ -71,6 +72,7 @@ The camel-smpps source connector supports 52 options, which
are listed below.
| *camel.component.smpps.pduProcessorDegree* | Sets the number of threads
which can read PDU and process them in parallel. | "3" | false | MEDIUM
| *camel.component.smpps.pduProcessorQueueCapacity* | Sets the capacity of the
working queue for PDU processing. | "100" | false | MEDIUM
| *camel.component.smpps.sessionStateListener* | You can refer to a
org.jsmpp.session.SessionStateListener in the Registry to receive callbacks
when the session state changed. | null | false | MEDIUM
+| *camel.component.smpps.singleDLR* | When true, the SMSC delivery receipt
would be requested only for the last segment of a multi-segment (long) message.
For short messages, with only 1 segment the behaviour is unchanged. | false |
false | MEDIUM
| *camel.component.smpps.transactionTimer* | Defines the maximum period of
inactivity allowed after a transaction, after which an SMPP entity may assume
that the session is no longer active. This timer may be active on either
communicating SMPP entity (i.e. SMSC or ESME). | "10000" | false | MEDIUM
| *camel.component.smpps.alphabet* | Defines encoding of data according the
SMPP 3.4 specification, section 5.2.19. 0: SMSC Default Alphabet 4: 8 bit
Alphabet 8: UCS2 Alphabet One of: [0] [4] [8] | null | false | MEDIUM
| *camel.component.smpps.dataCoding* | Defines the data coding according the
SMPP 3.4 specification, section 5.2.19. Example data encodings are: 0: SMSC
Default Alphabet 3: Latin 1 (ISO-8859-1) 4: Octet unspecified (8-bit binary) 8:
UCS2 (ISO/IEC-10646) 13: Extended Kanji JIS(X 0212-1990) | null | false | MEDIUM
@@ -100,8 +102,4 @@ The camel-smpps source connector has no transforms out of
the box.
The camel-smpps source connector has no aggregation strategies out of the box.
-
-
-
-
// kafka-connector options: END
