sent by light clients to their vendors
559320
function postJointToLightVendor(objJoint, handleResponse) {
	console.log('posting joint identified by unit ' + objJoint.unit.unit + ' to light vendor');
	requestFromLightVendor('post_joint', objJoint, function(ws, request, response){
		handleResponse(response);
	});
}
987551
function publish(conn, channel, indices, message) {
  var i
    , conn;
  for(i = 0;i < indices.length;i++) {
    conn = this._state.getClient(indices[i]);
    if(conn) {
      conn.write(message);
    }
  }
}
884632
protected function sendShopInformation()
    {
        if ($this->needToSendShopInformation()) {
            $onlineLicenseCheck = $this->getOnlineLicenseCheck();
            $onlineLicenseCheck->validateShopSerials();
            $this->updateNextCheckTime();
        }
    }
10059
function sendToMultiple(send, msg, destinations, type) {
  destinations = destinations instanceof Array && destinations || [destinations];
  destinations.forEach(function(destination) {
    var set, socketIds;
    set = subscriptions[type];
    if ((socketIds = set.members(destination))) {
      return socketIds.slice(0).forEach(function(socketId) {
        if (!send.socketId(socketId, msg, destination)) {
          return set.removeFromAll(socketId);
        }
      });
    }
  });
  return true;
}
411049
def publish(self, message_type, client_id, client_storage, *args, **kwargs):
        
        if self.connection.connected:
            message = self.exchange.Message(
                self.pack(message_type, client_id, client_storage, args, kwargs))
            self.exchange.publish(message, routing_key='')
133746
def send_mass_contributor_emails(self):
        """"""
        # If the report configuration is not active we only send to the debugging user.
        for contributor in self.contributors:
            if contributor.email not in EMAIL_SETTINGS.get("EXCLUDED", []):
                self.send_contributor_email(contributor)
578469
function(topics, cb) {
    var correlationId = _cbt.put(metaResponse(cb));
    var msg = envelope(meta.encode()
                           .correlation(correlationId)
                           .client(_options.clientId)
                           .topics(topics)
                           .end());
    sendMsg(msg, correlationId, cb);
  }
285471
def customer_transaction_request(amount, creditcard, gateway_options)
      { 'Command' => 'Sale',
        'ClientIP' => gateway_options[:ip],
        'isRecurring' => false,
        'Details' => transaction_details(amount, creditcard, gateway_options) }
    end
290716
def send_preview(self, recipients, personalize="fallback"):
        """"""
        body = {
            "PreviewRecipients": [recipients] if isinstance(recipients, str) else recipients,
            "Personalize": personalize}
        response = self._post(self.uri_for("sendpreview"), json.dumps(body))
1180576
def add_clients(session, verbose):
  """"""
  for ctype in ['Genuine', 'Impostor']:
    for cdid in userid_clients:
      cid = ctype + '_%d' % cdid
      if verbose>1: print("  Adding user '%s' of type '%s'..." % (cid, ctype))
      session.add(Client(cid, ctype, cdid))
1296343
def send(self, from_client, message, to_clients=None, transient=False, push_data=None):
        
        if isinstance(message, dict):
            message = json.dumps(message)
        params = {
            'from_peer': from_client,
            'conv_id': self.id,
            'transient': transient,
            'message': message,
        }
        if to_clients:
            params['to_peers'] = to_clients
        if push_data:
            params['push_data'] = push_data
        client.post('/rtm/messages', params=params).json()
1134541
function (done) {
      var index = 'users:' + user._id + ':clients'
      Client.__client.zrevrange(index, 0, -1, function (err, ids) {
        if (err) { return done(err) }
        done(null, ids)
      })
    }
361092
def send(self, sender: PytgbotApiBot):
        
        return sender.send_invoice(
            # receiver, self.media, disable_notification=self.disable_notification, reply_to_message_id=reply_id
            title=self.title, description=self.description, payload=self.payload, provider_token=self.provider_token, start_parameter=self.start_parameter, currency=self.currency, prices=self.prices, chat_id=self.receiver, reply_to_message_id=self.reply_id, provider_data=self.provider_data, photo_url=self.photo_url, photo_size=self.photo_size, photo_width=self.photo_width, photo_height=self.photo_height, need_name=self.need_name, need_phone_number=self.need_phone_number, need_email=self.need_email, need_shipping_address=self.need_shipping_address, send_phone_number_to_provider=self.send_phone_number_to_provider, send_email_to_provider=self.send_email_to_provider, is_flexible=self.is_flexible, disable_notification=self.disable_notification, reply_markup=self.reply_markup
        )
474638
def broadcast(self, clients, msg):
        
        json_msg = None

        count = 0

        for c in clients:
            sess = c.session
            if not sess.is_closed:
                if sess.send_expects_json:
                    if json_msg is None:
                        json_msg = proto.json_encode(msg)
                    sess.send_jsonified(json_msg, stats=False)
                else:
                    sess.send_message(msg, stats=False)

                count += 1

        self.stats.packSent(count)
173811
def post(self):
    """"""
    client_customer_id = self.request.get('clientCustomerId')
    if not client_customer_id:
      self.redirect('/')
    else:
      self.redirect('/showCampaigns?clientCustomerId=%s' % client_customer_id)
1101879
protected void doPublish(String tenantId, List<T> items, String subscriber,
            int retryCount, long delay) throws Exception {
        String data = mapper.writeValueAsString(items);

        TextMessage tm = session.createTextMessage(data);

        if (tenantId != null) {
            tm.setStringProperty("tenant", tenantId);
        }

        if (subscriber != null) {
            tm.setStringProperty("subscriber", subscriber);
        }

        tm.setIntProperty("retryCount", retryCount);

        if (delay > 0) {
            tm.setLongProperty("_AMQ_SCHED_DELIVERY", System.currentTimeMillis() + delay);
        }

        if (log.isLoggable(Level.FINEST)) {
            log.finest("Publish: " + tm);
        }

        producer.send(tm);
    }
127496
def update_shipment(self, resource_id, data):
        """"""
        return Shipments(self.client).on(self).update(resource_id, data)