Messaging and Queuing Jobs

The following topics describe job attributes that work with data processing platforms and services:

AWS SNS Job
AWS SQS Job
RabbitMQ Job

AWS SNS Job

AWS SNS (Simple Notification Service) is a cloud-based SNS that follows a Pub/Sub model and enables you to send notifications across various platforms and devices.

To create an AWS SNS job, see Creating a Job. For more information about this plug-in, see Control-M for AWS SNS.

The following example shows how to define a JSON Message Structure for the AWS SNS job:

Copy

"AWS SNS_Job_7": 
{
   "Type": "Job:AWS SNS",
   "ConnectionProfile": "AWSSNS",
   "Message Type": "Message To A Topic",
   "Topic Type": "Standard",
   "Target ARN": "Target ARN",
   "Json Message Structure": "checked",
   "Subject": "Subject",
   "Message": "{%4E    \"default\": \"A message.\",%4E    \"email\": \"A message for email.\",%4E    \"email-json\": \"A message for email (JSON).\",%4E    \"http\": \"A message for HTTP.\",%4E    \"https\": \"A message for HTTPS.\",%4E    \"sqs\": \"A message for Amazon SQS.\",%4E    \"lambda\": \"A message for Amazon Lambda Services.\"%4E}",
   "Attributes": "checked",
   "Attribute.1 Name": "Attribute1",
   "Attribute.1 Data Type": "String",
   "Attribute.1 Value": "Value1",
   "SMS Attributes": "checked",
   "Attributes": "checked",
   "Attribute.1 Name": "Attribute2",
   "Attribute.1 Data Type": "String",
   "Attribute.1 Value": "Value2",
   "Sender Identifier": "Sender ID",
   "Sender ID": "BMC",
   "Max Price": "1.0",
   "SMS Type": "Transactional"
}

The following table describes the AWS SNS job parameters.

Attribute	Message	Description
Connection Profile	All Types	Determines the authorization credentials that are used to connect Control-M to AWS SNS, as described in AWS SNS Connection Profile Parameters. Rules: Characters: 1−30 Case Sensitive: Yes Invalid Characters: Blank spaces.
Message Type	NA	Determines one of the following message types: Message To Topic Message To Individual
Topic Type	Message To Topic	Determines one of the following topic types where the message is published: Standard: High throughput with at-least-once delivery. FIFO: Processing messages exactly once and in order.
Individual Type	Message To Individual	Determines one of the following recipient types: Platform Application Phone Number
Target ARN	Message To Topic Message To Individual, Platform Application	Determines the Amazon Resource Name endpoint or resource where the message is published.
Subject	All Types	Defines the message title that is used in email notifications.
Message	All Types	Defines the message body.
Message Deduplication ID	Message To Topic, FIFO	Defines a unique identifier (token) for the message, which is used to prevent duplicate messages in FIFO topics.
Message Group ID	Message To Topic, FIFO	Determines the group identifier for the messages, which is used in FIFO topics to ensure that the messages are processed in order.
JSON Message Structure	Message To Topic, Standard	Determines whether to add the structure of the message payload, in JSON format, which allows multiple message formats within a single SNS notification as appears in the code example.
Attributes	Message To Topic	Determines whether to add additional metadata or properties associated with the message, such as time-to-live (TTL), or delivery retries, or just random customized data. Provide Name, Data Type (String, Array, Number, or Binary), and Value for each attribute.
SMS Attributes	Message To Topic Message To Individual, Phone Number	Determines whether to add attributes to the SMS messages. Provide Name, Data Type (String, Array, Number, or Binary), and Value for each attribute.
Sender Identifier	Message To Topic Message To Individual, Phone Number	Determines one of the following sender identities: Sender ID:Determines the alphanumeric identifier that appears as the sender of the SMS message. Origination Number: Determines the phone number that the SMS message originates from, which is used in countries that require a specific number format.
Max Price	Message To Topic, Message To Individual	Determines the maximum price that you are willing to pay for an SMS message.
SMS Type	Message To Topic, Message To Individual, Phone Number	(Optional) Determines one of the following types of SMS messages: Transactional Promotional Default Transactional
Phone Number	Message To Topic, Message To Individual, Phone Number	Determines the phone number of the SMS message recipient.
Push Notifications Attributes	Message To Individual, Platform Application	Determines the predefined attributes for push notifications.
Status Polling Frequency	All Types	(Optional) Determines the number of seconds to wait before Control-M checks the status or output of the job. Default: 10
Failure tolerance	All Types	Determines the number of times to check the job status before the job ends Not OK. Default: 3

AWS SQS Job

AWS Simple Queue Service (SQS) is a message queuing service that enables you to exchange messages between components without losing messages.

To create an AWS SQS job, see Creating a Job. For more information about this plug-in, see Control-M for AWS SQS.

The following example shows how to define a Manual JSON structure, which the user can manually add to a message body or to the attributes for custom data representation.

Copy

"QueueUrl": "https://sqs.<Region>.amazonaws.com/<accountNumber>/TestQueue.fifo",
   "Entries": [
   {
      "Id": "msg-id",
      "MessageBody": "Hello",
      "MessageDeduplicationId":"MDDP",
      "MessageGroupId":"MGID",
      "MessageAttributes": 
      {
         "Attribute1": 
         {
            "DataType": "String",
            "StringValue": "Value1"
         },
         "Attribute2": 
         {
            "DataType": "Number",
            "StringValue": "123"
         }
      }
   } ]

The following table describes the AWS SQS job parameters.

Attribute	Action	Description
Connection Profile	All Actions	Determines the authorization credentials that are used to connect Control-M to AWS SQS, as described in Data Processing and Analytics Connection Profiles. Rules: Characters: 1−30 Case Sensitive: Yes Invalid Characters: Blank spaces.
Action Type	NA	Determines one of the following message sending action types: Preset: Message sending is predefined. Manual: A user or an application triggers message sending.
Queue Type	Preset	Determines one of the following SQS queue types: Standard: May delivers messages more than once but has a larger capacity. FIFO: Delivers messages only once and in the first-in-first-out order.
Queue URL	Preset	Determines the unique SQS queue URL that is used to send, receive, and delete messages. https://sqs.eu-west-2.amazonaws.com/123123123/TestQueue.fifo
Message Body	Preset	Defines the message body.
Delay Seconds	Preset	Determines the number of seconds to wait before making the message visible and available to proceed.
Message Deduplication ID	Preset, FIFO	Defines a unique identifier (token) for the message, which is used to prevent duplicate messages in FIFO queue within 5-minute interval.
Message Group ID	Preset, FIFO	Determines the group identifier for the messages, which is used in the FIFO queue to ensure that the messages in the same group are processed in order.
Message Attributes	Preset	Determines whether to add additional metadata or properties associated with the message, such as time-to-live (TTL), or delivery retries, or just random customized data, in the following format: Name Data type Value
Attribute name	All Actions	Defines the message attribute name or key which is used to identify and retrieve the attribute value.
Attribute Data Type	All Actions	Determines one of the following message attribute data types: String Array Number Binary
Attribute Value	All Actions	Defines the message attribute content.
Manual JSON	All Actions	Defines a JSON structure, which the user can manually add to a message body or to the attributes for custom data representation as appears in the code example.

RabbitMQ Job

RabbitMQ is a message broker for applications that require message delivery and routing capabilities.

To create a RabbitMQ job, see Creating a Job. For more information about this plug-in, see Control-M for RabbitMQ.

The following table describes the RabbitMQ job type attributes.

Attribute	Description
Connection profile	Determines the authorization credentials that are used to connect Control-M to RabbitMQ, as described in RabbitMQ Connection Profile Parameters. Rules: Characters: 1−30 Case Sensitive: Yes Invalid Characters: Blank spaces.
Action	Determines one of the following actions to perform on RabbitMQ: Publish a Message Purge the Queue
Vhost	Defines the virtual hostname that connects to RabbitMQ. Virtual hosts do not share exchanges or queues between them.
Queue	Defines the name of the queue that contains the messages when you purge the queue.
Exchange	Defines the exchanges that take a message and route it into queues when you publish a message.
Routing Key	Defines the key that enables you to bind queues to exchanges when you publish a message.
Message to Publish	Defines the message content that you publish.
Message Encoding	Defines the encoding of the message that you publish. The encoding must be a string or Base64.
Properties	Defines the additional information that you can add to the message that you publish as comma-separated property:value pairs. {"app_id":"151515151515123",”app_name”:”Control-M}