src/Common/ServicesBuilder.php
public function createServiceBusService($connectionString)
    {
        $settings = ServiceBusSettings::createFromConnectionString(
            $connectionString
        );

        $httpClient = $this->httpClient();
        $serializer = $this->serializer();
        $serviceBusWrapper = new ServiceBusRestProxy(
            $httpClient,
            $settings->getServiceBusEndpointUri(),
            $serializer
        );

        // Adding headers filter
        $headers = [];

        $headersFilter = new HeadersFilter($headers);
        $serviceBusWrapper = $serviceBusWrapper->withFilter($headersFilter);

        $filter = $settings->getFilter();

        return $serviceBusWrapper->withFilter($filter);
    }
public function createServiceBusService($connectionString)
    {
        $settings = ServiceBusSettings::createFromConnectionString(
            $connectionString
        );

        $httpClient = $this->httpClient();
        $serializer = $this->serializer();
        $serviceBusWrapper = new ServiceBusRestProxy(
            $httpClient,
            $settings->getServiceBusEndpointUri(),
            $serializer
        );

        // Adding headers filter
        $headers = [];

        $headersFilter = new HeadersFilter($headers);
        $serviceBusWrapper = $serviceBusWrapper->withFilter($headersFilter);

        $filter = $settings->getFilter();

        return $serviceBusWrapper->withFilter($filter);
    }
public function createServiceBusService ( $ connectionString ) { $ settings = ServiceBusSettings :: createFromConnectionString ( $ connectionString ) ; $ httpClient = $ this -> httpClient ( ) ; $ serializer = $ this -> serializer ( ) ; $ serviceBusWrapper = new ServiceBusRestProxy ( $ httpClient , $ settings -> getServiceBusEndpointUri ( ) , $ serializer ) ; // Adding headers filter $ headers = [ ] ; $ headersFilter = new HeadersFilter ( $ headers ) ; $ serviceBusWrapper = $ serviceBusWrapper -> withFilter ( $ headersFilter ) ; $ filter = $ settings -> getFilter ( ) ; return $ serviceBusWrapper -> withFilter ( $ filter ) ; }
Builds a Service Bus object.

@param string $connectionString The configuration connection string

@return IServiceBus
Builds a Service Bus object .