Để tạo mới queue trong ActiveMQ Artemis, các bạn cần phải tạo mới address trước.
Tạo mới address
Để tạo address, trong trang Artemis Console, ở menu Artemis, các bạn hãy click chọn vào tab Addresses nhé!
Các address mà các bạn thấy ở hình trên là những address mặc định khi chúng ta mới cài đặt ActiveMQ Artemis đó các bạn!
Các bạn hãy nhấn nút Create address để tạo mới address nhé!
Các bạn hãy điền Address Name, chọn Routing Type là Anycast hay Multicast và nhấn nút Create Address để tạo mới address. Ví dụ của mình như sau:
Kết quả:
Như vậy là chúng ta đã tạo mới address thành công rồi đó các bạn! Bây giờ thì các bạn có thể tạo mới queue với address mới này rồi.
Tạo mới queue
Để tạo mới queue, các bạn hãy click vào nút 3 chấm theo chiều dọc ở dòng address tương ứng, rồi chọn Create Queue như sau:
Cửa sổ tạo mới queue sẽ hiển thị như sau:
Các thông tin mà chúng ta cần phải điền bao gồm:
- Queue Name: Tên của queue mà các bạn muốn tạo
- Routing Type: Nếu các bạn muốn tạo queue giống như queue trong JMS (message sẽ chỉ được gửi tới một consumer duy nhất) thì hãy chọn Anycast, còn nếu các bạn muốn giống topic trong JMS (message sẽ được gửi tới nhiều consumer khác nhau) thì hãy chọn Multicast.
- Durable: Check chọn option này nếu các bạn muốn queue vẫn sẽ tồn tại kể cả khi các bạn restart ActiveMQ Artemis.
- Filter: Sử dụng option này nếu các bạn muốn filter các message, phải thoả mãn filter thì các message mới được route tới queue này.
- Max Consumers: Nếu các bạn muốn giới hạn số lượng Consumer thì hãy điền một con số nào đó mà các bạn muốn, còn không muốn giới hạn thì cứ để giá trị mặc định là -1 các bạn nhé!
- Purge when no Consumers: Option này nhằm ngăn chặn việc queue sẽ nhận message khi không có consumer đang subscribe và nó cũng sẽ remove hết tất cả message nếu không có bất cứ consumer nào.
- Extra configuration: Một số cấu hình khác mà bạn có thể cấu hình, ví dụ như delay-before-dispatch hay auto-delete.
Ví dụ mình điền thông tin queue như sau:
Tiếp theo, các bạn hãy nhấn nút Create Queue để tạo mới queue nhé!
Kết quả của mình như sau:
Như vậy là chúng ta đã tạo mới queue trong ActiveMQ Artemis thành công rồi đó các bạn!
