@@ -99,23 +99,23 @@ ClusterBrokerClient.prototype.setBrokers = function (sccBrokerURIList) {
9999 } ) ( ) ;
100100 } ) ;
101101
102- let unusedsccBrokerURIList = Object . keys ( this . sccBrokerClientPools ) . filter ( ( clientURI ) => {
102+ let unusedSCCBrokerURIList = Object . keys ( this . sccBrokerClientPools ) . filter ( ( clientURI ) => {
103103 return ! brokerClientMap [ clientURI ] ;
104104 } ) ;
105- unusedsccBrokerURIList . forEach ( ( clientURI ) => {
105+ unusedSCCBrokerURIList . forEach ( ( clientURI ) => {
106106 let unusedClientPool = this . sccBrokerClientPools [ clientURI ] ;
107107 unusedClientPool . destroy ( ) ;
108108 delete this . sccBrokerClientPools [ clientURI ] ;
109109 } ) ;
110110
111111 let newSubscriptionsMap = { } ;
112112 fullSubscriptionList . forEach ( ( channelName ) => {
113- let targetsccBrokerURI = this . mapChannelNameToBrokerURI ( channelName ) ;
114- if ( ! newSubscriptionsMap [ targetsccBrokerURI ] ) {
115- newSubscriptionsMap [ targetsccBrokerURI ] = { } ;
113+ let targetSCCBrokerURI = this . mapChannelNameToBrokerURI ( channelName ) ;
114+ if ( ! newSubscriptionsMap [ targetSCCBrokerURI ] ) {
115+ newSubscriptionsMap [ targetSCCBrokerURI ] = { } ;
116116 }
117- if ( ! newSubscriptionsMap [ targetsccBrokerURI ] [ channelName ] ) {
118- newSubscriptionsMap [ targetsccBrokerURI ] [ channelName ] = true ;
117+ if ( ! newSubscriptionsMap [ targetSCCBrokerURI ] [ channelName ] ) {
118+ newSubscriptionsMap [ targetSCCBrokerURI ] [ channelName ] = true ;
119119 }
120120 } ) ;
121121
@@ -180,33 +180,33 @@ ClusterBrokerClient.prototype._subscribeClientPoolToChannelAndWatch = function (
180180} ;
181181
182182ClusterBrokerClient . prototype . subscribe = function ( channelName ) {
183- let targetsccBrokerURI = this . mapChannelNameToBrokerURI ( channelName ) ;
184- let targetsccBrokerClientPool = this . sccBrokerClientPools [ targetsccBrokerURI ] ;
185- if ( targetsccBrokerClientPool ) {
186- this . _subscribeClientPoolToChannelAndWatch ( targetsccBrokerClientPool , channelName ) ;
183+ let targetSCCBrokerURI = this . mapChannelNameToBrokerURI ( channelName ) ;
184+ let targetSCCBrokerClientPool = this . sccBrokerClientPools [ targetSCCBrokerURI ] ;
185+ if ( targetSCCBrokerClientPool ) {
186+ this . _subscribeClientPoolToChannelAndWatch ( targetSCCBrokerClientPool , channelName ) ;
187187 } else {
188188 let error = this . errors . NoMatchingSubscribeTargetError ( channelName ) ;
189189 this . emit ( 'error' , { error} ) ;
190190 }
191191} ;
192192
193193ClusterBrokerClient . prototype . unsubscribe = function ( channelName ) {
194- let targetsccBrokerURI = this . mapChannelNameToBrokerURI ( channelName ) ;
195- let targetsccBrokerClientPool = this . sccBrokerClientPools [ targetsccBrokerURI ] ;
196- if ( targetsccBrokerClientPool ) {
197- targetsccBrokerClientPool . unsubscribe ( channelName ) ;
198- targetsccBrokerClientPool . closeChannel ( channelName ) ;
194+ let targetSCCBrokerURI = this . mapChannelNameToBrokerURI ( channelName ) ;
195+ let targetSCCBrokerClientPool = this . sccBrokerClientPools [ targetSCCBrokerURI ] ;
196+ if ( targetSCCBrokerClientPool ) {
197+ targetSCCBrokerClientPool . unsubscribe ( channelName ) ;
198+ targetSCCBrokerClientPool . closeChannel ( channelName ) ;
199199 } else {
200200 let error = this . errors . NoMatchingUnsubscribeTargetError ( channelName ) ;
201201 this . emit ( 'error' , { error} ) ;
202202 }
203203} ;
204204
205205ClusterBrokerClient . prototype . invokePublish = function ( channelName , data ) {
206- let targetsccBrokerURI = this . mapChannelNameToBrokerURI ( channelName ) ;
207- let targetsccBrokerClientPool = this . sccBrokerClientPools [ targetsccBrokerURI ] ;
208- if ( targetsccBrokerClientPool ) {
209- targetsccBrokerClientPool . invokePublish ( channelName , data ) ;
206+ let targetSCCBrokerURI = this . mapChannelNameToBrokerURI ( channelName ) ;
207+ let targetSCCBrokerClientPool = this . sccBrokerClientPools [ targetSCCBrokerURI ] ;
208+ if ( targetSCCBrokerClientPool ) {
209+ targetSCCBrokerClientPool . invokePublish ( channelName , data ) ;
210210 } else {
211211 let error = this . errors . NoMatchingPublishTargetError ( channelName ) ;
212212 this . emit ( 'error' , { error} ) ;
0 commit comments