test_class.declarator: operations
test_class.modifier: @Mock
test_class.original_string: @Mock
  	KafkaOps operations;
test_class.type: KafkaOps
test_class.var_name: operations
test_class.declarator: producerChannels
test_class.modifier: @Mock
test_class.original_string: @Mock
  	CSourceProducerChannel producerChannels;
test_class.type: CSourceProducerChannel
test_class.var_name: producerChannels
test_class.declarator: csourceSubs
test_class.modifier: @InjectMocks
test_class.original_string: @InjectMocks
  	CSourceSubscriptionService csourceSubs;
test_class.type: CSourceSubscriptionService
test_class.var_name: csourceSubs
test_class.declarator: subsPayload
test_class.original_string: String subsPayload;
test_class.type: String
test_class.var_name: subsPayload
test_class.declarator: subs
test_class.original_string: Subscription subs;
test_class.type: Subscription
test_class.var_name: subs
test_class.file: Registry/RegistryManager/src/test/java/eu/neclab/ngsildbroker/registryhandler/service/CSourceSubscriptionServiceTest.java
test_class.identifier: CSourceSubscriptionServiceTest
test_case.body: @Test
  	public void subscribeTest() {
  		try {
  			Mockito.doReturn(true).when(operations).isMessageExists(any(), any());
  			URI uri=csourceSubs.subscribe(new SubscriptionRequest(subs, null));
  			
  			Assert.assertEquals(uri, new URI("urn:ngsi-ld:Subscription:7"));
  		}catch(Exception ex) {
  			Assert.fail();
  		}
  	}
test_case.class_method_signature: CSourceSubscriptionServiceTest.subscribeTest()
test_case.full_signature: @Test public void subscribeTest()
test_case.identifier: subscribeTest
test_case.invocations: isMessageExists when doReturn any any subscribe assertEquals fail
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void subscribeTest()
focal_class.declarator: logger = LogManager.getLogger(CSourceSubscriptionService.class)
focal_class.modifier: private final static
focal_class.original_string: private final static Logger logger = LogManager.getLogger(CSourceSubscriptionService.class);
focal_class.type: Logger
focal_class.var_name: logger
focal_class.declarator: nullArray = "null".getBytes()
focal_class.modifier: private final
focal_class.original_string: private final byte[] nullArray = "null".getBytes();
focal_class.type: byte[]
focal_class.var_name: nullArray
focal_class.declarator: kafkaOps
focal_class.modifier: @Autowired
  	@Qualifier("rmops")
focal_class.original_string: @Autowired
  	@Qualifier("rmops")
  	KafkaOps kafkaOps;
focal_class.type: KafkaOps
focal_class.var_name: kafkaOps
focal_class.declarator: objectMapper
focal_class.modifier: @Autowired
focal_class.original_string: @Autowired
  	ObjectMapper objectMapper;
focal_class.type: ObjectMapper
focal_class.var_name: objectMapper
focal_class.declarator: contextResolverService
focal_class.modifier: @Autowired
  	@Qualifier("rmconRes")
focal_class.original_string: @Autowired
  	@Qualifier("rmconRes")
  	ContextResolverBasic contextResolverService;
focal_class.type: ContextResolverBasic
focal_class.var_name: contextResolverService
focal_class.declarator: eurekaClient
focal_class.modifier: @Autowired
focal_class.original_string: @Autowired
  	EurekaClient eurekaClient;
focal_class.type: EurekaClient
focal_class.var_name: eurekaClient
focal_class.declarator: cSourceService
focal_class.modifier: @Autowired
focal_class.original_string: @Autowired
  	CSourceService cSourceService;
focal_class.type: CSourceService
focal_class.var_name: cSourceService
focal_class.declarator: notificationHandler
focal_class.original_string: CSourceNotificationHandler notificationHandler;
focal_class.type: CSourceNotificationHandler
focal_class.var_name: notificationHandler
focal_class.declarator: internalNotificationHandler
focal_class.original_string: CSourceNotificationHandler internalNotificationHandler;
focal_class.type: CSourceNotificationHandler
focal_class.var_name: internalNotificationHandler
focal_class.declarator: producerChannel
focal_class.modifier: private final
focal_class.original_string: private final CSourceProducerChannel producerChannel;
focal_class.type: CSourceProducerChannel
focal_class.var_name: producerChannel
focal_class.declarator: shapeFactory = JtsSpatialContext.GEO.getShapeFactory()
focal_class.original_string: JtsShapeFactory shapeFactory = JtsSpatialContext.GEO.getShapeFactory();
focal_class.type: JtsShapeFactory
focal_class.var_name: shapeFactory
focal_class.declarator: subscriptionId2Subscription = new HashMap<URI, Subscription>()
focal_class.original_string: HashMap<URI, Subscription> subscriptionId2Subscription = new HashMap<URI, Subscription>();
focal_class.type: HashMap<URI, Subscription>
focal_class.var_name: subscriptionId2Subscription
focal_class.declarator: idBasedSubscriptions = ArrayListMultimap.create()
focal_class.original_string: ArrayListMultimap<String, Subscription> idBasedSubscriptions = ArrayListMultimap.create();
focal_class.type: ArrayListMultimap<String, Subscription>
focal_class.var_name: idBasedSubscriptions
focal_class.declarator: typeBasedSubscriptions = ArrayListMultimap.create()
focal_class.original_string: ArrayListMultimap<String, Subscription> typeBasedSubscriptions = ArrayListMultimap.create();
focal_class.type: ArrayListMultimap<String, Subscription>
focal_class.var_name: typeBasedSubscriptions
focal_class.declarator: idPatternBasedSubscriptions = ArrayListMultimap.create()
focal_class.original_string: ArrayListMultimap<String, Subscription> idPatternBasedSubscriptions = ArrayListMultimap.create();
focal_class.type: ArrayListMultimap<String, Subscription>
focal_class.var_name: idPatternBasedSubscriptions
focal_class.declarator: remoteNotifyCallbackId2InternalSub = new HashMap<String, Subscription>()
focal_class.original_string: HashMap<String, Subscription> remoteNotifyCallbackId2InternalSub = new HashMap<String, Subscription>();
focal_class.type: HashMap<String, Subscription>
focal_class.var_name: remoteNotifyCallbackId2InternalSub
focal_class.declarator: BOOTSTRAP_SERVERS
focal_class.modifier: @Value("${bootstrap.servers}")
focal_class.original_string: @Value("${bootstrap.servers}")
  	String BOOTSTRAP_SERVERS;
focal_class.type: String
focal_class.var_name: BOOTSTRAP_SERVERS
focal_class.file: Registry/RegistryManager/src/main/java/eu/neclab/ngsildbroker/registryhandler/service/CSourceSubscriptionService.java
focal_class.identifier: CSourceSubscriptionService
focal_class.class_method_signature: CSourceSubscriptionService.CSourceSubscriptionService(CSourceProducerChannel producerChannel)
focal_class.full_signature: public  CSourceSubscriptionService(CSourceProducerChannel producerChannel)
focal_class.identifier: CSourceSubscriptionService
focal_class.modifiers: public
focal_class.parameters: (CSourceProducerChannel producerChannel)
focal_class.signature:  CSourceSubscriptionService(CSourceProducerChannel producerChannel)
focal_class.class_method_signature: CSourceSubscriptionService.loadStoredSubscriptions()
focal_class.full_signature: @PostConstruct private void loadStoredSubscriptions()
focal_class.identifier: loadStoredSubscriptions
focal_class.modifiers: @PostConstruct private
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void loadStoredSubscriptions()
focal_class.class_method_signature: CSourceSubscriptionService.querySubscription(URI id)
focal_class.full_signature: public Subscription querySubscription(URI id)
focal_class.identifier: querySubscription
focal_class.modifiers: public
focal_class.parameters: (URI id)
focal_class.return: Subscription
focal_class.signature: Subscription querySubscription(URI id)
focal_class.class_method_signature: CSourceSubscriptionService.subscribe(SubscriptionRequest subscriptionRequest)
focal_class.full_signature: public URI subscribe(SubscriptionRequest subscriptionRequest)
focal_class.identifier: subscribe
focal_class.modifiers: public
focal_class.parameters: (SubscriptionRequest subscriptionRequest)
focal_class.return: URI
focal_class.signature: URI subscribe(SubscriptionRequest subscriptionRequest)
focal_class.class_method_signature: CSourceSubscriptionService.subscribe(SubscriptionRequest subscriptionRequest, boolean sync)
focal_class.full_signature: public URI subscribe(SubscriptionRequest subscriptionRequest, boolean sync)
focal_class.identifier: subscribe
focal_class.modifiers: public
focal_class.parameters: (SubscriptionRequest subscriptionRequest, boolean sync)
focal_class.return: URI
focal_class.signature: URI subscribe(SubscriptionRequest subscriptionRequest, boolean sync)
focal_class.class_method_signature: CSourceSubscriptionService.generateInitialNotification(Subscription subscription)
focal_class.full_signature: private void generateInitialNotification(Subscription subscription)
focal_class.identifier: generateInitialNotification
focal_class.modifiers: private
focal_class.parameters: (Subscription subscription)
focal_class.return: void
focal_class.signature: void generateInitialNotification(Subscription subscription)
focal_class.class_method_signature: CSourceSubscriptionService.syncToMessageBus(SubscriptionRequest subscriptionRequest)
focal_class.full_signature: private void syncToMessageBus(SubscriptionRequest subscriptionRequest)
focal_class.identifier: syncToMessageBus
focal_class.modifiers: private
focal_class.parameters: (SubscriptionRequest subscriptionRequest)
focal_class.return: void
focal_class.signature: void syncToMessageBus(SubscriptionRequest subscriptionRequest)
focal_class.class_method_signature: CSourceSubscriptionService.generateUniqueSubId(Subscription subscription)
focal_class.full_signature: private URI generateUniqueSubId(Subscription subscription)
focal_class.identifier: generateUniqueSubId
focal_class.modifiers: private
focal_class.parameters: (Subscription subscription)
focal_class.return: URI
focal_class.signature: URI generateUniqueSubId(Subscription subscription)
focal_class.class_method_signature: CSourceSubscriptionService.unsubscribe(URI id)
focal_class.full_signature: public boolean unsubscribe(URI id)
focal_class.identifier: unsubscribe
focal_class.modifiers: public
focal_class.parameters: (URI id)
focal_class.return: boolean
focal_class.signature: boolean unsubscribe(URI id)
focal_class.class_method_signature: CSourceSubscriptionService.updateSubscription(Subscription subscription)
focal_class.full_signature: public Subscription updateSubscription(Subscription subscription)
focal_class.identifier: updateSubscription
focal_class.modifiers: public
focal_class.parameters: (Subscription subscription)
focal_class.return: Subscription
focal_class.signature: Subscription updateSubscription(Subscription subscription)
focal_class.class_method_signature: CSourceSubscriptionService.getAllSubscriptions(int limit)
focal_class.full_signature: public List<Subscription> getAllSubscriptions(int limit)
focal_class.identifier: getAllSubscriptions
focal_class.modifiers: public
focal_class.parameters: (int limit)
focal_class.return: List<Subscription>
focal_class.signature: List<Subscription> getAllSubscriptions(int limit)
focal_class.class_method_signature: CSourceSubscriptionService.getSubscription(URI subscriptionId)
focal_class.full_signature: public Subscription getSubscription(URI subscriptionId)
focal_class.identifier: getSubscription
focal_class.modifiers: public
focal_class.parameters: (URI subscriptionId)
focal_class.return: Subscription
focal_class.signature: Subscription getSubscription(URI subscriptionId)
focal_class.class_method_signature: CSourceSubscriptionService.checkSubscriptions(CSourceRegistration cSourceRegistration, TriggerReason triggerReason)
focal_class.full_signature: public void checkSubscriptions(CSourceRegistration cSourceRegistration, TriggerReason triggerReason)
focal_class.identifier: checkSubscriptions
focal_class.modifiers: public
focal_class.parameters: (CSourceRegistration cSourceRegistration, TriggerReason triggerReason)
focal_class.return: void
focal_class.signature: void checkSubscriptions(CSourceRegistration cSourceRegistration, TriggerReason triggerReason)
focal_class.class_method_signature: CSourceSubscriptionService.getSubsForIdPattern(String idPattern)
focal_class.full_signature: private Collection<? extends Subscription> getSubsForIdPattern(String idPattern)
focal_class.identifier: getSubsForIdPattern
focal_class.modifiers: private
focal_class.parameters: (String idPattern)
focal_class.return: Collection<? extends Subscription>
focal_class.signature: Collection<? extends Subscription> getSubsForIdPattern(String idPattern)
focal_class.class_method_signature: CSourceSubscriptionService.generateNotificationEntry(CSourceRegistration regEntry, Subscription subscription,
  			TriggerReason triggerReason)
focal_class.full_signature: private CSourceNotification generateNotificationEntry(CSourceRegistration regEntry, Subscription subscription,
  			TriggerReason triggerReason)
focal_class.identifier: generateNotificationEntry
focal_class.modifiers: private
focal_class.parameters: (CSourceRegistration regEntry, Subscription subscription,
  			TriggerReason triggerReason)
focal_class.return: CSourceNotification
focal_class.signature: CSourceNotification generateNotificationEntry(CSourceRegistration regEntry, Subscription subscription,
  			TriggerReason triggerReason)
focal_class.class_method_signature: CSourceSubscriptionService.addAttribMatch(Information info, EntityInfo regEntityInfo, Subscription subscription,
  			ArrayList<EntityInfo> newEntityInfos, Information newInfo)
focal_class.full_signature: private void addAttribMatch(Information info, EntityInfo regEntityInfo, Subscription subscription,
  			ArrayList<EntityInfo> newEntityInfos, Information newInfo)
focal_class.identifier: addAttribMatch
focal_class.modifiers: private
focal_class.parameters: (Information info, EntityInfo regEntityInfo, Subscription subscription,
  			ArrayList<EntityInfo> newEntityInfos, Information newInfo)
focal_class.return: void
focal_class.signature: void addAttribMatch(Information info, EntityInfo regEntityInfo, Subscription subscription,
  			ArrayList<EntityInfo> newEntityInfos, Information newInfo)
focal_class.class_method_signature: CSourceSubscriptionService.extractRelationShips(Information info, Subscription subscription)
focal_class.full_signature: private Set<String> extractRelationShips(Information info, Subscription subscription)
focal_class.identifier: extractRelationShips
focal_class.modifiers: private
focal_class.parameters: (Information info, Subscription subscription)
focal_class.return: Set<String>
focal_class.signature: Set<String> extractRelationShips(Information info, Subscription subscription)
focal_class.class_method_signature: CSourceSubscriptionService.extractProperties(Information info, Subscription subscription)
focal_class.full_signature: private Set<String> extractProperties(Information info, Subscription subscription)
focal_class.identifier: extractProperties
focal_class.modifiers: private
focal_class.parameters: (Information info, Subscription subscription)
focal_class.return: Set<String>
focal_class.signature: Set<String> extractProperties(Information info, Subscription subscription)
focal_class.class_method_signature: CSourceSubscriptionService.evaluateGeoQuery(LDGeoQuery geoQuery, Geometry<?> location)
focal_class.full_signature: private boolean evaluateGeoQuery(LDGeoQuery geoQuery, Geometry<?> location)
focal_class.identifier: evaluateGeoQuery
focal_class.modifiers: private
focal_class.parameters: (LDGeoQuery geoQuery, Geometry<?> location)
focal_class.return: boolean
focal_class.signature: boolean evaluateGeoQuery(LDGeoQuery geoQuery, Geometry<?> location)
focal_class.class_method_signature: CSourceSubscriptionService.evaluateGeoQuery(LDGeoQuery geoQuery, Geometry<?> location, double expandArea)
focal_class.full_signature: private boolean evaluateGeoQuery(LDGeoQuery geoQuery, Geometry<?> location, double expandArea)
focal_class.identifier: evaluateGeoQuery
focal_class.modifiers: private
focal_class.parameters: (LDGeoQuery geoQuery, Geometry<?> location, double expandArea)
focal_class.return: boolean
focal_class.signature: boolean evaluateGeoQuery(LDGeoQuery geoQuery, Geometry<?> location, double expandArea)
focal_class.class_method_signature: CSourceSubscriptionService.getPatternBasedSubs(String key)
focal_class.full_signature: private Collection<? extends Subscription> getPatternBasedSubs(String key)
focal_class.identifier: getPatternBasedSubs
focal_class.modifiers: private
focal_class.parameters: (String key)
focal_class.return: Collection<? extends Subscription>
focal_class.signature: Collection<? extends Subscription> getPatternBasedSubs(String key)
focal_class.class_method_signature: CSourceSubscriptionService.handleInternalSub(Message<byte[]> message)
focal_class.full_signature: @KafkaListener(topics = "${submanager.subscription.topic}", groupId = "csourcemanager") public void handleInternalSub(Message<byte[]> message)
focal_class.identifier: handleInternalSub
focal_class.modifiers: @KafkaListener(topics = "${submanager.subscription.topic}", groupId = "csourcemanager") public
focal_class.parameters: (Message<byte[]> message)
focal_class.return: void
focal_class.signature: void handleInternalSub(Message<byte[]> message)
focal_class.class_method_signature: CSourceSubscriptionService.evaluateRegGeoQuery(LDGeoQuery subGeoQuery, Geometry<?> geoValue)
focal_class.full_signature: private boolean evaluateRegGeoQuery(LDGeoQuery subGeoQuery, Geometry<?> geoValue)
focal_class.identifier: evaluateRegGeoQuery
focal_class.modifiers: private
focal_class.parameters: (LDGeoQuery subGeoQuery, Geometry<?> geoValue)
focal_class.return: boolean
focal_class.signature: boolean evaluateRegGeoQuery(LDGeoQuery subGeoQuery, Geometry<?> geoValue)
focal_class.class_method_signature: CSourceSubscriptionService.checkSubscriptions(CSourceRegistration prevCSourceRegistration,
  			CSourceRegistration newCSourceRegistration)
focal_class.full_signature: public boolean checkSubscriptions(CSourceRegistration prevCSourceRegistration,
  			CSourceRegistration newCSourceRegistration)
focal_class.identifier: checkSubscriptions
focal_class.modifiers: public
focal_class.parameters: (CSourceRegistration prevCSourceRegistration,
  			CSourceRegistration newCSourceRegistration)
focal_class.return: boolean
focal_class.signature: boolean checkSubscriptions(CSourceRegistration prevCSourceRegistration,
  			CSourceRegistration newCSourceRegistration)
focal_method.body: public URI subscribe(SubscriptionRequest subscriptionRequest) throws ResponseException {
  		return subscribe(subscriptionRequest, true);
  	}
focal_method.class_method_signature: CSourceSubscriptionService.subscribe(SubscriptionRequest subscriptionRequest)
focal_method.full_signature: public URI subscribe(SubscriptionRequest subscriptionRequest)
focal_method.identifier: subscribe
focal_method.invocations: subscribe
focal_method.modifiers: public
focal_method.parameters: (SubscriptionRequest subscriptionRequest)
focal_method.return: URI
focal_method.signature: URI subscribe(SubscriptionRequest subscriptionRequest)