GitLocker: The Coding Marketplace

Description:

aigadjangoamqp 0.0.2

merupakan package khusus django untuk keperluan berkomunikasi dengan rabbitmq

Quick start

Tambahkan “aiga_amqp” ke INSTALLED_APPS pada file settings.py:
INSTALLED_APPS = [
...
'aiga_amqp',
]

A.1 Message Sender
Berikut contoh kode untuk mengirim message:
from aiga_amqp.core import send_queue

send_queue('nama channel', message='ini pesan')

A.2 Compete Consumer
Berikut merupakan langkah untuk consume antrian message secara “compete” atau bergantian.

Pada folder app yang anda inginkan, tambahkan file consumer.py
Pada file consumer.py buat function untuk menangani message seperti contoh dibawah ini:
def consumer(channel, method, properties, body):
print('saya telah baru saja melakukan sesuatu hal yang penting disini ...')

Pada file apps.py override method ready dan lakukan perintah seperti contoh berikut untuk mengeksekusi consumer.py:
from django.apps import AppConfig

class ExampleConfig(AppConfig):
default_auto_field = 'django.db.models.BigAutoField'
name = 'example'

def ready(self) -> None:
from aiga_amqp.core import AMQPListener
from .consumer import consumer
listener = AMQPListener()
listener.consume(consumer, channel_name='your channel name')

Jalankan django

B.1 Publish Message
segera

B.2 Subscribe Message
segera

Settings Variable
Terdapat beberapa variable yang bisa digunakan pada settings.py beserta default value nya:
AIGA_AMQP = {
'HOST' : 'localhost', //alamat host dari rabbitmq
'PORT' : 5672, //port dari rabbitmq
'CREDENTIAL' : False, //set menjadi True jika menggunakan USERNAME dan PASSWORD
'USERNAME' : None, //username untuk mengakses rabbitmq
'PASSWORD' : None, //password untuk mengakses rabbitmq
'HEARTBEAT' : 600,
'TIMEOUT' : 300
}