The present disclosure is directed to systems and methods for parallel and scalable processing of messages containing telemetry data at an administrator system. The administrator system can receive a large number of messages containing telemetry data from many dispenser machines in a short amount of time. To receive and process those messages, the systems and methods of the present disclosure provide a message queuer to queue the messages (or at least the telemetry data in the messages) in a plurality of queues and a different thread or process for each of the plurality of queues. Each thread or process can pull messages out of its assigned queue in order and process the telemetry data of the messages. The threads or processes can run on one or more central processing unit cores at the administrator system. This setup allows for horizontal scaling in terms of message processing throughput.

Beverage shrinkage monitoring technology is disclosed and is used to reduce beverage shrinkage at bars, clubs, restaurants, and other establishments that dispense beverages. Bottles are topped with wireless (RFID/Bluetooth/WiFi) enabled liquor/wine nozzles that only pour when handled by appropriate staff members who wear RFID wristbands or bracelets. The wireless (RFID/Bluetooth/WiFi) enabled liquor/wine nozzles also report sales to a point of sales (POS) system. Beer taps include proprietary wireless (RFID/Bluetooth/WiFi) enabled beer tap adapters that are mounted to or embedded in the beer taps.

The present disclosure is directed to systems and methods for parallel and scalable processing of messages containing telemetry data at an administrator system. The administrator system can receive a large number of messages containing telemetry data from many dispenser machines in a short amount of time. To receive and process those messages, the systems and methods of the present disclosure provide a message queuer to queue the messages (or at least the telemetry data in the messages) in a plurality of queues and a different thread or process for each of the plurality of queues. Each thread or process can pull messages out of its assigned queue in order and process the telemetry data of the messages. The threads or processes can run on one or more central processing unit cores at the administrator system. This setup allows for horizontal scaling in terms of message processing throughput.

Disclosed are embodiments of a beverage dispensing system that controls the flow of beverage based on information acquisitioned from a marker associated with a vessel for the beverage. The system utilizes a switching apparatus located in the tap of the dispensing unit that can selectively enable mechanical connection between the hand lever of the tap and the stem based on the information acquisitioned. Some embodiments include a hand tilt device for automatically controlling the flow of beverage, and a vessel tilt device to adjusting the tilt of the vessel so as to achieve a preferred pour.

Systems, apparatus, methods, and articles of manufacture provide for a beverage dispensing system configured to form one of a plurality of available types of carbonated and non-carbonated beverage types in response to a user selection.

In an approach for pouring control, a processor recognizes that a user requests material from a dispenser with a container. A processor evaluates the container via one or more sensors. A processor determines that the user is allowed to receive the material. A processor, in response to determining that the user is allowed to receive the material, triggers the dispenser to pour the material into the container. A processor monitors the dispenser pouring the material. A processor determines that an anomaly is detected during pouring the material. A processor, in response to determining that the anomaly is detected during pouring the material, signals the dispenser to stop the pouring.

In an approach for pouring control, a processor recognizes that a user requests material from a dispenser with a container. A processor evaluates the container via one or more sensors. A processor determines that the user is allowed to receive the material. A processor, in response to determining that the user is allowed to receive the material, triggers the dispenser to pour the material into the container. A processor monitors the dispenser pouring the material. A processor determines that an anomaly is detected during pouring the material. A processor, in response to determining that the anomaly is detected during pouring the material, signals the dispenser to stop the pouring.

A drink vending apparatus is disclosed. A user provides user commands from a smart device to a control unit that comprises drink requests from the user. In response thereto, ingredients are dispensed from ingredient cartridges into a mixing container, and the mixed ingredients are dispensed from the mixing container into a receptacle.

A controlled pourer that may include a locking mechanism for locking the controlled pourer to a bottle; a communication module; a flow control mechanism that is configured to control an output of fluid, during a liquid consumption iteration, from the bottle under a control of one or more commands received by the communication module; and a flow meter for monitoring an amount of fluid outputted by the flow control mechanism during the fluid consumption iteration. The communication module is configured to output information regarding the amount of fluid consumed during the fluid consumption operation. Once locked to the bottle the controller pourer prevents a bypass of the fluid control mechanism.

The present disclosure is directed to systems and methods for parallel and scalable processing of messages containing telemetry data at an administrator system. The administrator system can receive a large number of messages containing telemetry data from many dispenser machines in a short amount of time. To receive and process those messages, the systems and methods of the present disclosure provide a message queuer to queue the messages (or at least the telemetry data in the messages) in a plurality of queues and a different thread or process for each of the plurality of queues. Each thread or process can pull messages out of its assigned queue in order and process the telemetry data of the messages. The threads or processes can run on one or more central processing unit cores at the administrator system. This setup allows for horizontal scaling in terms of message processing throughput.