Intelligent Data Flow Control Valve

A method comprising:

• monitoring an activity stream of an integration layer that is configured to (a) receive events from an upstream system and (b) transmit data to a downstream system responsive to the events;
• detecting, while monitoring the activity stream, a recoverable error between the integration layer and the downstream system;
• responsive to detecting the recoverable error:
• instructing the upstream system to pause sending additional events to the integration layer;
• after instructing the upstream system to pause sending additional events to the integration layer:
• detecting that the recoverable error is fixed;
• and
• responsive to detecting that the recoverable error is fixed:
• instructing the upstream system to resume sending additional events to the integration layer;
• wherein the method is performed by at least one device including a hardware processor.

A system comprising:

• at least one device including a hardware processor;
• the system being configured to perform operations comprising:
• monitoring an activity stream of an integration layer that is configured to (a) receive events from an upstream system and (b) transmit data to a downstream system responsive to the events;
• detecting, while monitoring the activity stream, a recoverable error between the integration layer and the downstream system;
• responsive to detecting the recoverable error:
• instructing the upstream system to pause sending additional events to the integration layer;
• after instructing the upstream system to pause sending additional events to the integration layer:
• detecting that the recoverable error is fixed;
• and
• responsive to detecting that the recoverable error is fixed:
• instructing the upstream system to resume sending additional events to the integration layer.