Module: Activerecord::Oracle::Queue::Schema::Statements
- Defined in:
- lib/activerecord/oracle/queue/schema.rb
Instance Method Summary collapse
- #add_queue(queue_name, payload_name: "message_t", payload_object: "json VARCHAR2(4000)") ⇒ Object
- #remove_queue(queue_name, payload_name: "message_t") ⇒ Object
Instance Method Details
#add_queue(queue_name, payload_name: "message_t", payload_object: "json VARCHAR2(4000)") ⇒ Object
21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 |
# File 'lib/activerecord/oracle/queue/schema.rb', line 21 def add_queue(queue_name, payload_name: "message_t", payload_object: "json VARCHAR2(4000)") schema, queue_name = remove_schema_from_queue_name(queue_name) raise ArgumentError, "The queue name can not be longer than 20 chars." if queue_name.length > 20 (payload_name, payload_object) execute(<<-SQL) BEGIN DBMS_AQADM.CREATE_QUEUE_TABLE( queue_table => '#{queue_name}_tab', queue_payload_type => '#{payload_name}' ); DBMS_AQADM.CREATE_QUEUE( queue_name => '#{queue_name}', queue_table => '#{queue_name}_tab' ); DBMS_AQADM.START_QUEUE( queue_name => '#{queue_name}' ); END; SQL add_queue_package(binding) end |
#remove_queue(queue_name, payload_name: "message_t") ⇒ Object
47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 |
# File 'lib/activerecord/oracle/queue/schema.rb', line 47 def remove_queue(queue_name, payload_name: "message_t") schema, queue_name = remove_schema_from_queue_name(queue_name) execute(<<-SQL) BEGIN DBMS_AQADM.STOP_QUEUE( queue_name => '#{queue_name}' ); DBMS_AQADM.DROP_QUEUE( queue_name => '#{queue_name}' ); DBMS_AQADM.DROP_QUEUE_TABLE( queue_table => '#{queue_name}_tab' ); END; SQL (payload_name) execute("DROP PACKAGE #{queue_name}_queue") end |