test_class.file: series/src/test/java/com/barchart/feed/series/network/NetworkSchemaTest.java
test_class.identifier: NetworkSchemaTest
test_case.body: @Test
      public void testGetPublishers() {
      	NetworkSchema.setSchemaFilePath("testNetworks.txt");
      	NetworkSchema.reloadDefinitions();
      	
      	NetworkDescriptor schema = NetworkSchema.getNetwork("PivotPoint");
      	assertNotNull(schema);
      	
      	assertEquals("PivotPoint", schema.getNetworkName());
      	assertEquals(8, schema.getNodeDescriptors().size());
      	
      	List<AnalyticNodeDescriptor> publishers = schema.getPublishers();
      	assertTrue(!publishers.isEmpty());
      	assertEquals(7, publishers.size());
      	for(AnalyticNodeDescriptor and : publishers) {
      		assertTrue(!and.getSpecifier().equals("PP_R2"));
      	}
      }
test_case.class_method_signature: NetworkSchemaTest.testGetPublishers()
test_case.full_signature: @Test public void testGetPublishers()
test_case.identifier: testGetPublishers
test_case.invocations: setSchemaFilePath reloadDefinitions getNetwork assertNotNull assertEquals getNetworkName assertEquals size getNodeDescriptors getPublishers assertTrue isEmpty assertEquals size assertTrue equals getSpecifier
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testGetPublishers()
focal_class.declarator: DEFAULT_SCHEMA_FILENAME = "networks.txt"
focal_class.modifier: private static final
focal_class.original_string: private static final String DEFAULT_SCHEMA_FILENAME = "networks.txt";
focal_class.type: String
focal_class.var_name: DEFAULT_SCHEMA_FILENAME
focal_class.declarator: IDX_NETWORK_NAME = 0
focal_class.modifier: private static final
focal_class.original_string: private static final int IDX_NETWORK_NAME = 0;
focal_class.type: int
focal_class.var_name: IDX_NETWORK_NAME
focal_class.declarator: IDX_NODE_NAME = 1
focal_class.modifier: private static final
focal_class.original_string: private static final int IDX_NODE_NAME = 1;
focal_class.type: int
focal_class.var_name: IDX_NODE_NAME
focal_class.declarator: IDX_ANALYTIC_CLASS = 2
focal_class.modifier: private static final
focal_class.original_string: private static final int IDX_ANALYTIC_CLASS = 2;
focal_class.type: int
focal_class.var_name: IDX_ANALYTIC_CLASS
focal_class.declarator: IDX_CONSTRUCTOR_ARGS = 3
focal_class.modifier: private static final
focal_class.original_string: private static final int IDX_CONSTRUCTOR_ARGS = 3;
focal_class.type: int
focal_class.var_name: IDX_CONSTRUCTOR_ARGS
focal_class.declarator: IDX_OUTPUT_KEY = 4
focal_class.modifier: private static final
focal_class.original_string: private static final int IDX_OUTPUT_KEY = 4;
focal_class.type: int
focal_class.var_name: IDX_OUTPUT_KEY
focal_class.declarator: IDX_INPUT_CONFIG = 5
focal_class.modifier: private static final
focal_class.original_string: private static final int IDX_INPUT_CONFIG = 5;
focal_class.type: int
focal_class.var_name: IDX_INPUT_CONFIG
focal_class.declarator: networkDefinitions = new HashMap<String, List<String[]>>()
focal_class.modifier: private static
focal_class.original_string: private static Map<String,List<String[]>> networkDefinitions = new HashMap<String, List<String[]>>();
focal_class.type: Map<String,List<String[]>>
focal_class.var_name: networkDefinitions
focal_class.declarator: allDescriptors = new LinkedHashMap<String, AnalyticNodeDescriptor>()
focal_class.modifier: private static
focal_class.original_string: private static Map<String, AnalyticNodeDescriptor> allDescriptors = new LinkedHashMap<String, AnalyticNodeDescriptor>();
focal_class.type: Map<String, AnalyticNodeDescriptor>
focal_class.var_name: allDescriptors
focal_class.declarator: descriptorsByNetwork = new LinkedHashMap<String, List<AnalyticNodeDescriptor>>()
focal_class.modifier: private static
focal_class.original_string: private static Map<String, List<AnalyticNodeDescriptor>> descriptorsByNetwork = new LinkedHashMap<String, List<AnalyticNodeDescriptor>>();
focal_class.type: Map<String, List<AnalyticNodeDescriptor>>
focal_class.var_name: descriptorsByNetwork
focal_class.declarator: schemaFileName = DEFAULT_SCHEMA_FILENAME
focal_class.modifier: private static
focal_class.original_string: private static String schemaFileName = DEFAULT_SCHEMA_FILENAME;
focal_class.type: String
focal_class.var_name: schemaFileName
focal_class.declarator: name
focal_class.modifier: private
focal_class.original_string: private String name;
focal_class.type: String
focal_class.var_name: name
focal_class.declarator: nodes
focal_class.modifier: private
focal_class.original_string: private List<AnalyticNodeDescriptor> nodes;
focal_class.type: List<AnalyticNodeDescriptor>
focal_class.var_name: nodes
focal_class.declarator: mainPublishers
focal_class.modifier: private
focal_class.original_string: private List<AnalyticNodeDescriptor> mainPublishers;
focal_class.type: List<AnalyticNodeDescriptor>
focal_class.var_name: mainPublishers
focal_class.file: series/src/main/java/com/barchart/feed/series/network/NetworkSchema.java
focal_class.identifier: NetworkSchema
focal_class.interfaces: implements NetworkDescriptor
focal_class.class_method_signature: NetworkSchema.NetworkSchema(String name)
focal_class.full_signature: public  NetworkSchema(String name)
focal_class.identifier: NetworkSchema
focal_class.modifiers: public
focal_class.parameters: (String name)
focal_class.signature:  NetworkSchema(String name)
focal_class.class_method_signature: NetworkSchema.NetworkSchema(String name, List<AnalyticNodeDescriptor> nodes)
focal_class.full_signature: public  NetworkSchema(String name, List<AnalyticNodeDescriptor> nodes)
focal_class.identifier: NetworkSchema
focal_class.modifiers: public
focal_class.parameters: (String name, List<AnalyticNodeDescriptor> nodes)
focal_class.signature:  NetworkSchema(String name, List<AnalyticNodeDescriptor> nodes)
focal_class.class_method_signature: NetworkSchema.getSpecifier()
focal_class.full_signature: @Override public String getSpecifier()
focal_class.identifier: getSpecifier
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: String
focal_class.signature: String getSpecifier()
focal_class.class_method_signature: NetworkSchema.getType()
focal_class.full_signature: @Override public NodeType getType()
focal_class.identifier: getType
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: NodeType
focal_class.signature: NodeType getType()
focal_class.class_method_signature: NetworkSchema.getNetworkName()
focal_class.full_signature: @Override public String getNetworkName()
focal_class.identifier: getNetworkName
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: String
focal_class.signature: String getNetworkName()
focal_class.class_method_signature: NetworkSchema.setNetworkName(String name)
focal_class.full_signature: @Override public void setNetworkName(String name)
focal_class.identifier: setNetworkName
focal_class.modifiers: @Override public
focal_class.parameters: (String name)
focal_class.return: void
focal_class.signature: void setNetworkName(String name)
focal_class.class_method_signature: NetworkSchema.getNodeDescriptors()
focal_class.full_signature: @SuppressWarnings("unchecked") @Override public List<AnalyticNodeDescriptor> getNodeDescriptors()
focal_class.identifier: getNodeDescriptors
focal_class.modifiers: @SuppressWarnings("unchecked") @Override public
focal_class.parameters: ()
focal_class.return: List<AnalyticNodeDescriptor>
focal_class.signature: List<AnalyticNodeDescriptor> getNodeDescriptors()
focal_class.class_method_signature: NetworkSchema.setNodeDescriptors(List<T> nodes)
focal_class.full_signature: @SuppressWarnings("unchecked") @Override public void setNodeDescriptors(List<T> nodes)
focal_class.identifier: setNodeDescriptors
focal_class.modifiers: @SuppressWarnings("unchecked") @Override public
focal_class.parameters: (List<T> nodes)
focal_class.return: void
focal_class.signature: void setNodeDescriptors(List<T> nodes)
focal_class.class_method_signature: NetworkSchema.getPublishers()
focal_class.full_signature: @SuppressWarnings("unchecked") @Override public List<AnalyticNodeDescriptor> getPublishers()
focal_class.identifier: getPublishers
focal_class.modifiers: @SuppressWarnings("unchecked") @Override public
focal_class.parameters: ()
focal_class.return: List<AnalyticNodeDescriptor>
focal_class.signature: List<AnalyticNodeDescriptor> getPublishers()
focal_class.class_method_signature: NetworkSchema.hasNetworkByName(String networkName)
focal_class.full_signature: public static boolean hasNetworkByName(String networkName)
focal_class.identifier: hasNetworkByName
focal_class.modifiers: public static
focal_class.parameters: (String networkName)
focal_class.return: boolean
focal_class.signature: boolean hasNetworkByName(String networkName)
focal_class.class_method_signature: NetworkSchema.getSchemaFilePath()
focal_class.full_signature: public static String getSchemaFilePath()
focal_class.identifier: getSchemaFilePath
focal_class.modifiers: public static
focal_class.parameters: ()
focal_class.return: String
focal_class.signature: String getSchemaFilePath()
focal_class.class_method_signature: NetworkSchema.setSchemaFilePath(String filePath)
focal_class.full_signature: public static void setSchemaFilePath(String filePath)
focal_class.identifier: setSchemaFilePath
focal_class.modifiers: public static
focal_class.parameters: (String filePath)
focal_class.return: void
focal_class.signature: void setSchemaFilePath(String filePath)
focal_class.class_method_signature: NetworkSchema.lookup(String name, int timeFrames)
focal_class.full_signature: public static AnalyticNodeDescriptor lookup(String name, int timeFrames)
focal_class.identifier: lookup
focal_class.modifiers: public static
focal_class.parameters: (String name, int timeFrames)
focal_class.return: AnalyticNodeDescriptor
focal_class.signature: AnalyticNodeDescriptor lookup(String name, int timeFrames)
focal_class.class_method_signature: NetworkSchema.lookup(SeriesSubscription subscription)
focal_class.full_signature: public static AnalyticNodeDescriptor lookup(SeriesSubscription subscription)
focal_class.identifier: lookup
focal_class.modifiers: public static
focal_class.parameters: (SeriesSubscription subscription)
focal_class.return: AnalyticNodeDescriptor
focal_class.signature: AnalyticNodeDescriptor lookup(SeriesSubscription subscription)
focal_class.class_method_signature: NetworkSchema.reloadDefinitions()
focal_class.full_signature: public static void reloadDefinitions()
focal_class.identifier: reloadDefinitions
focal_class.modifiers: public static
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void reloadDefinitions()
focal_class.class_method_signature: NetworkSchema.getNetwork(String name)
focal_class.full_signature: public static NetworkSchema getNetwork(String name)
focal_class.identifier: getNetwork
focal_class.modifiers: public static
focal_class.parameters: (String name)
focal_class.return: NetworkSchema
focal_class.signature: NetworkSchema getNetwork(String name)
focal_class.class_method_signature: NetworkSchema.loadDescriptor(String[] entry)
focal_class.full_signature: @SuppressWarnings("unchecked") public static AnalyticNodeDescriptor loadDescriptor(String[] entry)
focal_class.identifier: loadDescriptor
focal_class.modifiers: @SuppressWarnings("unchecked") public static
focal_class.parameters: (String[] entry)
focal_class.return: AnalyticNodeDescriptor
focal_class.signature: AnalyticNodeDescriptor loadDescriptor(String[] entry)
focal_class.class_method_signature: NetworkSchema.loadAllDescriptors()
focal_class.full_signature: public static void loadAllDescriptors()
focal_class.identifier: loadAllDescriptors
focal_class.modifiers: public static
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void loadAllDescriptors()
focal_class.class_method_signature: NetworkSchema.loadDefinitionsFile(String fileName)
focal_class.full_signature: public static void loadDefinitionsFile(String fileName)
focal_class.identifier: loadDefinitionsFile
focal_class.modifiers: public static
focal_class.parameters: (String fileName)
focal_class.return: void
focal_class.signature: void loadDefinitionsFile(String fileName)
focal_class.class_method_signature: NetworkSchema.loadFromStream(InputStream stream)
focal_class.full_signature: public static void loadFromStream(InputStream stream)
focal_class.identifier: loadFromStream
focal_class.modifiers: public static
focal_class.parameters: (InputStream stream)
focal_class.return: void
focal_class.signature: void loadFromStream(InputStream stream)
focal_method.body: @SuppressWarnings("unchecked")
      @Override
      public List<AnalyticNodeDescriptor> getPublishers() {
      	if(nodes == null || nodes.size() < 1) {
      		throw new IllegalStateException("Network: " + name + " was initialized with no nodes!");
      	}
      	
      	if(mainPublishers == null) {
      		mainPublishers = new ArrayList<AnalyticNodeDescriptor>();
      	}
      	
      	int len = nodes.size();
      	for(int i = 0;i < len;i++) {
      		AnalyticNodeDescriptor currCheck = nodes.get(i);
      		boolean isPublisher = true;
      		for(int j = 0;j < len;j++) {
      			AnalyticNodeDescriptor iter = nodes.get(j);
      			if(!(isPublisher = !iter.getInputNodeDescriptors().contains(currCheck))) {
      				break;
      			}
      		}
      		if(isPublisher) mainPublishers.add(currCheck);
      	}
      	return mainPublishers;
      }
focal_method.class_method_signature: NetworkSchema.getPublishers()
focal_method.full_signature: @SuppressWarnings("unchecked") @Override public List<AnalyticNodeDescriptor> getPublishers()
focal_method.identifier: getPublishers
focal_method.invocations: size size get get contains getInputNodeDescriptors add
focal_method.modifiers: @SuppressWarnings("unchecked") @Override public
focal_method.parameters: ()
focal_method.return: List<AnalyticNodeDescriptor>
focal_method.signature: List<AnalyticNodeDescriptor> getPublishers()