Commits · 2d510fb4213bb9f05a46310b8bb9199b9cb3ee4e · RadioObservatory / LOFAR

Jul 05, 2019
- SW-772 : log stack trace on service handler exception. log rpc_args and rpc_kwargs · 2d510fb4
  Jorrit Schaap authored 5 years ago
  
  2d510fb4
- SW-772 : re doesn't like escaping in unicode, so use raw strings · 351370fc
  Jorrit Schaap authored 5 years ago
  
  351370fc
- SW-772 : only read rabbitmq credentials on production/test · d35638f2
  Jorrit Schaap authored 5 years ago
  
  d35638f2
Jul 04, 2019
- SW-772 : no more need for expensive logging of receiver.nr_of_messages_in_queue · 96bcf8e7
  Jorrit Schaap authored 5 years ago
  
  96bcf8e7
Jul 02, 2019
- SW-720 : added nr_of_messages_in_queue to __all__ · b50b8bde
  Jorrit Schaap authored 5 years ago
  
  b50b8bde
Jun 28, 2019
- SW-720 : added requests required package · 60c0fa40
  Jorrit Schaap authored 5 years ago
  
  60c0fa40
- SW-699 : fixed nr_of_messages_in_queue using requests and rabbitmq REST api · 1dcd50f0
  Jorrit Schaap authored 5 years ago
  
  1dcd50f0
- SW-699 : minor improvement · 955afce5
  Jorrit Schaap authored 5 years ago
  
  955afce5
- SW-699 : added auto_delete flag, and set it to True for TemporaryQueue's · dd9f927d
  Jorrit Schaap authored 5 years ago
  
  dd9f927d
- SW-699 : test frombus.nr_of_messages_in_queue · 3997edda
  Jorrit Schaap authored 5 years ago
  
  3997edda
Jun 25, 2019
- SW-720 : proper error handling in BusListener __enter__ · 8d617372
  Jorrit Schaap authored 5 years ago
  
  8d617372
Jun 24, 2019
- SW-699 : fixe/implemented priorities on messages/queues · b4a8a1fd
  Jorrit Schaap authored 5 years ago
  
  b4a8a1fd
Jun 20, 2019
- SW-699 : raise in BusListener when it is detected that the provided handler is... · 2af8f926
  Jorrit Schaap authored 5 years ago
  
  SW-699: raise in BusListener when it is detected that the provided handler is an empty template handler
  2af8f926
- SW-699 : raise MessagingRuntimeError when BusListener thread(s) don't startup · 4399c3c2
  Jorrit Schaap authored 5 years ago
  
  4399c3c2
- SW-699 : raise MessageFactoryError · b91040ce
  Jorrit Schaap authored 5 years ago
  
  b91040ce
Jun 18, 2019
- SW-705 : Merged RabbitMQ branch back to LOFAR-4 _0 branch · 14f88e7d
  Auke Klazema authored 5 years ago
  
  14f88e7d
- SW-699 : added UsingToBusMixin, and (re)use that in all the... · ed515e08
  Jorrit Schaap authored 5 years ago
  
  SW-699: added UsingToBusMixin, and (re)use that in all the ServiceMessageHandlers and some AbstractMessageHandler derivatives
  ed515e08
- SW-705 : Fix test and convert PipelineControl to new Messaging Framework · ea3ca83d
  Auke Klazema authored 5 years ago
  
  ea3ca83d
- SW-699 : RPCTimeoutException · 5196a4c1
  Jorrit Schaap authored 5 years ago
  
  5196a4c1
Jun 17, 2019
- SW-705 : Add test for correct rejection behaviour · 1862fc05
  Auke Klazema authored 5 years ago
  
  1862fc05
- SW-699 : removed obselete test · 0b5a8034
  Jorrit Schaap authored 5 years ago
  
  0b5a8034
- SW-699 : fixed test t_RPC based on new messaging and rpc modules · 2af42c0d
  Jorrit Schaap authored 5 years ago
  
  2af42c0d
- SW-699 : added RPCException · 74a1b349
  Jorrit Schaap authored 5 years ago
  
  74a1b349
Jun 14, 2019
- SW-699 : fixed doctest. Skip tests if no broker available · bf468ca2
  Jorrit Schaap authored 5 years ago
  
  bf468ca2
- SW-699 : added listener type to designated_queue_name · 6419aa18
  Jorrit Schaap authored 5 years ago
  
  6419aa18
Jun 13, 2019
- SW-699 : logging · 0cd475d3
  Jorrit Schaap authored 5 years ago
  
  0cd475d3
- SW-699 : linelength · bd97585a
  Jorrit Schaap authored 5 years ago
  
  bd97585a
- SW-699 : do not prefetch any messages · adfd1a07
  Jorrit Schaap authored 5 years ago
  
  adfd1a07
- SW-699 : fixed doctest, be explicit in ack/reject message · f1f77100
  Jorrit Schaap authored 5 years ago
  
  f1f77100
- SW-699 : make sure the messages are 'persistent' and survive server restarts · b2d69f32
  Jorrit Schaap authored 5 years ago
  
  b2d69f32
Jun 11, 2019
- SW-699 : logging · 1e0b2908
  Jorrit Schaap authored 5 years ago
  
  1e0b2908
- SW-699 : logging · ed8a0eb3
  Jorrit Schaap authored 5 years ago
  
  ed8a0eb3
- SW-699 : log level · b4fad5b3
  Jorrit Schaap authored 5 years ago
  
  b4fad5b3
- SW-699 : logging · fab43c61
  Jorrit Schaap authored 5 years ago
  
  fab43c61
- SW-699 : fixed imports · dcb509bb
  Jorrit Schaap authored 5 years ago
  
  dcb509bb
- SW-699 : do not use direct_address anymore. only send messages to the exchange... · 654eb406
  Jorrit Schaap authored 5 years ago
  
  SW-699: do not use direct_address anymore. only send messages to the exchange with a proper routing_key
  654eb406
- SW-699 : fixed doctest. added check for ack/reject lofar message. reuse current... · 51b972ec
  Jorrit Schaap authored 5 years ago
  
  SW-699: fixed doctest. added check for ack/reject lofar message. reuse current queue connection when getting nr_of_messages_in_queue.
  51b972ec
- SW-699 : remove leading whitespace when removing lineseps as well · 6c8f94a9
  Jorrit Schaap authored 5 years ago
  
  6c8f94a9
Jun 07, 2019

SW-699 : make distinction between DEFAULT_BUS_TIMEOUT and DEFAULT_RPC_TIMEOUT · b28d04f8
Jorrit Schaap authored 5 years ago

b28d04f8

: added documentation to RPCClientContextManagerMixin. renamed... · bf5c99cb

Jorrit Schaap authored 5 years ago

SW-699: added documentation to RPCClientContextManagerMixin. renamed rpc_service.py module tp rpc.py, and it's classes to RPCClient and RPCService. Moved Request and ReplyMessage into rpc.py module. Mader MessageFactory and used it in FromBus and rpc.py

bf5c99cb