Didacticiels ActiveMQ

Les didacticiels suivants vous montrent comment créer et connecter vos agents ActiveMQ. Pour utiliser l'exemple de code Java ActiveMQ, vous devez installer le kit de développement Java édition Standard et apporter des modifications de code.

Rubriques

• Création et configuration d'un réseau d'agents Amazon MQ

• Connexion d'une application Java à votre agent Amazon MQ

• Intégration des agents ActiveMQ avec LDAP

• Étape 3 : (Facultatif) Se connecter à une AWS Lambda fonction

• Création d'un utilisateur de courtier ActiveMQ

• Modifier un utilisateur de courtier ActiveMQ

• Supprimer un utilisateur de courtier ActiveMQ

• Exemples pratiques d'utilisation de Java Message Service (JMS) avec ActiveMQ

Étape 3 : (Facultatif) Se connecter à une AWS Lambda fonction

AWS Lambda peut se connecter à votre courtier Amazon MQ et en consommer les messages. Lorsque vous connectez un agent à Lambda, vous créez un mappage de la source d'événement qui lit les messages d'une file d'attente et appelle la fonction de manière synchrone. Le mappage de la source d'événements que vous créez lit les messages de votre agent par lots et les convertit en une charge utile Lambda sous la forme d'un objet JSON.

Pour connecter votre agent à une fonction Lambda

1. Ajoutez les autorisations de rôle IAM suivantes au rôle d'exécution de votre fonction Lambda.

   • mq : DescribeBroker

   • EC2 : CreateNetworkInterface

   • EC2 : DeleteNetworkInterface

   • EC2 : DescribeNetworkInterfaces

   • EC2 : DescribeSecurityGroups

   • EC2 : DescribeSubnets

   • EC2 : DescribeVpcs

   • journaux : CreateLogGroup

   • journaux : CreateLogStream

   • journaux : PutLogEvents

   • responsable des secrets : GetSecretValue

   Note

   Sans les autorisations IAM nécessaires, votre fonction ne sera pas en mesure de lire correctement les enregistrements des ressources Amazon MQ.

2. (Facultatif) Si vous avez créé un agent sans accès public, vous devez effectuer l'une des opérations suivantes pour permettre à Lambda de se connecter à votre agent :

   • Configurez une passerelle NAT par sous-réseau public. Pour plus d'informations, consultez Accès à Internet et aux services pour les fonctions connectées à un VPC dans le Guide du développeur AWS Lambda .

   • Créez une connexion entre votre Amazon Virtual Private Cloud (Amazon VPC) et Lambda à l'aide d'un point de terminaison VPC. Votre Amazon VPC doit également se connecter à AWS Security Token Service (AWS STS) et aux points de terminaison Secrets Manager. Pour plus d'informations, consultez Configuration de points de terminaison de VPC d'interface pour Lambda dans leGuide du développeur AWS Lambda .

3. Configurez votre agent en tant que source d'événement pour une fonction Lambda à l'aide de la AWS Management Console. Vous pouvez également utiliser la create-event-source-mapping AWS Command Line Interface commande.

4. Écrivez du code pour votre fonction Lambda pour traiter les messages consommés par votre agent. La charge utile Lambda récupérée par votre mappage de source d'événement dépend du type de moteur de l'agent. Voici un exemple de charge utile Lambda pour une file d'attente Amazon MQ for ActiveMQ.

   Note

   Dans cet exemple, testQueue est le nom de la file d'attente.

   {
     "eventSource": "aws:amq",
     "eventSourceArn": "arn:aws:mq:us-west-2:112556298976:broker:test:b-9bcfa592-423a-4942-879d-eb284b418fc8",
     "messages": {
       [
         {
           "messageID": "ID:b-9bcfa592-423a-4942-879d-eb284b418fc8-1.mq.us-west-2.amazonaws.com-37557-1234520418293-4:1:1:1:1",
           "messageType": "jms/text-message",
           "data": "QUJDOkFBQUE=",
           "connectionId": "myJMSCoID",
           "redelivered": false,
           "destination": {
             "physicalname": "testQueue" 
           }, 
           "timestamp": 1598827811958,
           "brokerInTime": 1598827811958,
           "brokerOutTime": 1598827811959
         },
         {
           "messageID": "ID:b-9bcfa592-423a-4942-879d-eb284b418fc8-1.mq.us-west-2.amazonaws.com-37557-1234520418293-4:1:1:1:1",
           "messageType":"jms/bytes-message",
           "data": "3DTOOW7crj51prgVLQaGQ82S48k=",
           "connectionId": "myJMSCoID1",
           "persistent": false,
           "destination": {
             "physicalname": "testQueue" 
           }, 
           "timestamp": 1598827811958,
           "brokerInTime": 1598827811958,
           "brokerOutTime": 1598827811959
         }
       ]
     }
   }

Pour plus d'informations sur la connexion d'Amazon MQ à Lambda, les options prises en charge par Lambda pour une source d'événement Amazon MQ et les erreurs de mappage de source d'événement, consultez Utilisation de Lambda avec Amazon MQ dans le Guide du développeur AWS Lambda .