Java ObserverDataConsumer类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中com.arjuna.databroker.data.connector.ObserverDataConsumer类的典型用法代码示例。如果您正苦于以下问题：Java ObserverDataConsumer类的具体用法？Java ObserverDataConsumer怎么用？Java ObserverDataConsumer使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

ObserverDataConsumer类属于com.arjuna.databroker.data.connector包，在下文中一共展示了ObserverDataConsumer类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: simpleInvocation

import com.arjuna.databroker.data.connector.ObserverDataConsumer; //导入依赖的package包/类
@Test
public void simpleInvocation()
{
    DataFlowNodeLifeCycleControl dataFlowNodeLifeCycleControl = new TestJEEDataFlowNodeLifeCycleControl();

    String                     name                       = "XSSF Row To JSON Data Processor";
    Map<String, String>        properties                 = Collections.emptyMap();
    XSSFRowToJSONDataProcessor xssfRowToJSONDataProcessor = new XSSFRowToJSONDataProcessor(name, properties);

    dataFlowNodeLifeCycleControl.completeCreationAndActivateDataFlowNode(UUID.randomUUID().toString(), xssfRowToJSONDataProcessor, null);

    File file = new File("Test01.xlsx");

    ((ObserverDataConsumer<File>) xssfRowToJSONDataProcessor.getDataConsumer(File.class)).consume(null, file);

    dataFlowNodeLifeCycleControl.removeDataFlowNode(xssfRowToJSONDataProcessor);
}

开发者ID:arjuna-technologies，项目名称:Apache-POI_DataBroker_PlugIn，代码行数:18，代码来源:SimpleRowToJSONTest.java

示例2: simplestConversion

import com.arjuna.databroker.data.connector.ObserverDataConsumer; //导入依赖的package包/类
@Test
public void simplestConversion()
{
    DataFlowNodeLifeCycleControl dataFlowNodeLifeCycleControl = new TestJEEDataFlowNodeLifeCycleControl();

    DummyDataSource dummyDataSource        = new DummyDataSource("Dummy Data Source", Collections.<String, String>emptyMap());
    DataProcessor   shapeFileDataProcessor = new ShapeFileConverterDataProcessor("ShapeFile Converter Data Processor", Collections.<String, String>emptyMap());
    DummyDataSink   dummyDataSink          = new DummyDataSink("Dummy Data Sink", Collections.<String, String>emptyMap());

    dataFlowNodeLifeCycleControl.completeCreationAndActivateDataFlowNode(UUID.randomUUID().toString(), dummyDataSource, null);
    dataFlowNodeLifeCycleControl.completeCreationAndActivateDataFlowNode(UUID.randomUUID().toString(), shapeFileDataProcessor, null);
    dataFlowNodeLifeCycleControl.completeCreationAndActivateDataFlowNode(UUID.randomUUID().toString(), dummyDataSink, null);

    ((ObservableDataProvider<File>) dummyDataSource.getDataProvider(File.class)).addDataConsumer((ObserverDataConsumer<File>) shapeFileDataProcessor.getDataConsumer(File.class));
    ((ObservableDataProvider<String>) shapeFileDataProcessor.getDataProvider(String.class)).addDataConsumer((ObserverDataConsumer<String>) dummyDataSink.getDataConsumer(String.class));

    File testFile = new File("/tmp/Gully_point/Gully_point.shp");
    dummyDataSource.sendData(testFile);

    dataFlowNodeLifeCycleControl.removeDataFlowNode(dummyDataSource);
    dataFlowNodeLifeCycleControl.removeDataFlowNode(shapeFileDataProcessor);
    dataFlowNodeLifeCycleControl.removeDataFlowNode(dummyDataSink);

}

开发者ID:arjuna-technologies，项目名称:GeoAPI_DataBroker_PlugIn，代码行数:25，代码来源:ConverterTest.java

示例3: startupJob

import com.arjuna.databroker.data.connector.ObserverDataConsumer; //导入依赖的package包/类
@PostConstruct
public void startupJob()
{
    logger.log(Level.INFO, "StartupJob.startupJob");
    String              name       = "Test Job";
    Map<String, String> properties = new HashMap<String, String>();
    properties.put(BatchDataProcessor.JOBID_PROPERTYNAME, "testJob");

    BatchDataProcessor batchDataProcessor = new BatchDataProcessor(name, properties);

    ObserverDataConsumer<Object> dataConsumer = (ObserverDataConsumer<Object>) batchDataProcessor.getDataConsumer(Object.class);
    dataConsumer.consume(null, "Test Data");
}

开发者ID:arjuna-technologies，项目名称:JEEBatch_DataBroker_Support，代码行数:14，代码来源:StartupJob.java

示例4: BatchDataProvider

import com.arjuna.databroker.data.connector.ObserverDataConsumer; //导入依赖的package包/类
public BatchDataProvider(DataFlowNode dataFlowNode)
{
    logger.log(Level.FINE, "BatchDataProvider.BatchDataProvider");

    _id            = UUID.randomUUID().toString();
    _dataFlowNode  = dataFlowNode;
    _dataConsumers = new LinkedList<ObserverDataConsumer<Object>>();
}

开发者ID:arjuna-technologies，项目名称:JEEBatch_DataBroker_Support，代码行数:9，代码来源:BatchDataProvider.java

示例5: getDataConsumers

import com.arjuna.databroker.data.connector.ObserverDataConsumer; //导入依赖的package包/类
@Override
public Collection<ObserverDataConsumer<Object>> getDataConsumers()
{
    logger.log(Level.FINE, "BatchDataProvider.getDataConsumers");

    return Collections.unmodifiableList(_dataConsumers);
}

开发者ID:arjuna-technologies，项目名称:JEEBatch_DataBroker_Support，代码行数:8，代码来源:BatchDataProvider.java

示例6: addDataConsumer

import com.arjuna.databroker.data.connector.ObserverDataConsumer; //导入依赖的package包/类
@Override
public void addDataConsumer(ObserverDataConsumer<Object> dataConsumer)
{
    logger.log(Level.FINE, "BatchDataProvider.addDataConsumer");

    _dataConsumers.add(dataConsumer);
}

开发者ID:arjuna-technologies，项目名称:JEEBatch_DataBroker_Support，代码行数:8，代码来源:BatchDataProvider.java

示例7: removeDataConsumer

import com.arjuna.databroker.data.connector.ObserverDataConsumer; //导入依赖的package包/类
@Override
public void removeDataConsumer(ObserverDataConsumer<Object> dataConsumer)
{
    logger.log(Level.FINE, "BatchDataProvider.removeDataConsumer");

    _dataConsumers.remove(dataConsumer);
}

开发者ID:arjuna-technologies，项目名称:JEEBatch_DataBroker_Support，代码行数:8，代码来源:BatchDataProvider.java

示例8: produce

import com.arjuna.databroker.data.connector.ObserverDataConsumer; //导入依赖的package包/类
@Override
public void produce(Object data)
{
    logger.log(Level.FINE, "BatchDataProvider.produce");

    for (ObserverDataConsumer<Object> dataConsumer: _dataConsumers)
        dataConsumer.consume(this, data);
}

开发者ID:arjuna-technologies，项目名称:JEEBatch_DataBroker_Support，代码行数:9，代码来源:BatchDataProvider.java

示例9: getDataFlowLinks

import com.arjuna.databroker.data.connector.ObserverDataConsumer; //导入依赖的package包/类
private List<DataFlowNodeLinkDTO> getDataFlowLinks(DataProvider<?> dataProducer)
{
    List<DataFlowNodeLinkDTO> dataFlowLinks = new LinkedList<DataFlowNodeLinkDTO>();

    if (dataProducer instanceof ObservableDataProvider<?>)
    {
        ObservableDataProvider<?> observableDataProvider = (ObservableDataProvider<?>) dataProducer;
        for (ObserverDataConsumer<?> dataConsumer: observableDataProvider.getDataConsumers())
            dataFlowLinks.add(new DataFlowNodeLinkDTO(dataProducer.getDataFlowNode().getName(), dataConsumer.getDataFlowNode().getName()));
    }

    return dataFlowLinks;
}

开发者ID:RISBIC，项目名称:DataBroker，代码行数:14，代码来源:DataFlowWS.java

示例10: DefaultObservableDataProvider

import com.arjuna.databroker.data.connector.ObserverDataConsumer; //导入依赖的package包/类
public DefaultObservableDataProvider(DataFlowNode dataFlowNode)
{
    logger.log(Level.FINE, "DefaultObservableDataProvider: " + dataFlowNode);

    _dataFlowNode  = dataFlowNode;
    _dataConsumers = new LinkedList<ObserverDataConsumer<T>>();
}

开发者ID:RISBIC，项目名称:DataBroker，代码行数:8，代码来源:DefaultObservableDataProvider.java

示例11: DummyObservableDataProvider

import com.arjuna.databroker.data.connector.ObserverDataConsumer; //导入依赖的package包/类
public DummyObservableDataProvider(DataFlowNode dataFlowNode)
{
    logger.log(Level.FINE, "DefaultObservableDataProvider: " + dataFlowNode);

    _dataFlowNode  = dataFlowNode;
    _dataConsumers = new LinkedList<ObserverDataConsumer<T>>();
}

开发者ID:arjuna-technologies，项目名称:TestSupport_DataBroker_Utilities，代码行数:8，代码来源:DummyObservableDataProvider.java

示例12: simplestChain

import com.arjuna.databroker.data.connector.ObserverDataConsumer; //导入依赖的package包/类
@Test
public void simplestChain()
{
	DataFlowNodeLifeCycleControl dataFlowNodeLifeCycleControl = new TestJEEDataFlowNodeLifeCycleControl();

    SimpleDataSource    simpleDataSource    = new SimpleDataSource("Simple Data Source", Collections.<String, String>emptyMap());
    SimpleDataProcessor simpleDataProcessor = new SimpleDataProcessor("Simple Data Processor", Collections.<String, String>emptyMap());
    SimpleDataSink      simpleDataSink      = new SimpleDataSink("Simple Data Sink", Collections.<String, String>emptyMap());

    dataFlowNodeLifeCycleControl.completeCreationAndActivateDataFlowNode(UUID.randomUUID().toString(), simpleDataSource, null);
    dataFlowNodeLifeCycleControl.completeCreationAndActivateDataFlowNode(UUID.randomUUID().toString(), simpleDataProcessor, null);
    dataFlowNodeLifeCycleControl.completeCreationAndActivateDataFlowNode(UUID.randomUUID().toString(), simpleDataSink, null);

    ((ObservableDataProvider<String>) simpleDataSource.getDataProvider(String.class)).addDataConsumer((ObserverDataConsumer<String>) simpleDataProcessor.getDataConsumer(String.class));
    ((ObservableDataProvider<String>) simpleDataProcessor.getDataProvider(String.class)).addDataConsumer((ObserverDataConsumer<String>) simpleDataSink.getDataConsumer(String.class));

    assertEquals("Simple DataSource count", 0, simpleDataSource.getCount());
    assertEquals("Simple DataProcessor count", 0, simpleDataProcessor.getCount());
    assertEquals("Simple DataSink count", 0, simpleDataSink.getCount());

    simpleDataSource.dummyGetData("Data Bundle 1");
    simpleDataSource.dummyGetData("Data Bundle 2");
    simpleDataSource.dummyGetData("Data Bundle 3");
    simpleDataSource.dummyGetData("Data Bundle 4");

    dataFlowNodeLifeCycleControl.removeDataFlowNode(simpleDataSource);
    dataFlowNodeLifeCycleControl.removeDataFlowNode(simpleDataProcessor);
    dataFlowNodeLifeCycleControl.removeDataFlowNode(simpleDataSink);

    assertArrayEquals("Unexpected history at DataSink", new String[]{"[Data Bundle 1]", "[Data Bundle 2]", "[Data Bundle 3]", "[Data Bundle 4]"}, simpleDataSink.getSentHistory().toArray());
    
    assertEquals("Simple DataSource count", 4, simpleDataSource.getCount());
    assertEquals("Simple DataProcessor count", 4, simpleDataProcessor.getCount());
    assertEquals("Simple DataSink count", 4, simpleDataSink.getCount());
}

开发者ID:arjuna-technologies，项目名称:Simple_DataBroker_PlugIn，代码行数:36，代码来源:ChainingTest.java

示例13: createResourceAsString

import com.arjuna.databroker.data.connector.ObserverDataConsumer; //导入依赖的package包/类
@Test
public void createResourceAsString()
{
    try
    {
        CKANAPIProperties ckanAPIProperties = new CKANAPIProperties("ckanapi.properties");

        if (! ckanAPIProperties.isLoaded())
        {
            logger.log(Level.INFO, "SKIPPING TEST 'AppendFileStoreCKANDataServiceTest.createResourceAsString', no propertiles file");
            return;
        }

        DataFlowNodeLifeCycleControl dataFlowNodeLifeCycleControl = new TestJEEDataFlowNodeLifeCycleControl();

        String              name       = "AppendFileStoreCKANDataService";
        Map<String, String> properties = new HashMap<String, String>();
        properties.put(AppendFileStoreCKANDataService.CKANROOTURL_PROPERTYNAME, ckanAPIProperties.getCKANRootURL());
        properties.put(AppendFileStoreCKANDataService.PACKAGEID_PROPERTYNAME, ckanAPIProperties.getPackageId());
        properties.put(AppendFileStoreCKANDataService.APIKEY_PROPERTYNAME, ckanAPIProperties.getAPIKey());

        DummyDataSource                dummyDataSource                = new DummyDataSource("Dummy Data Source", Collections.<String, String>emptyMap());
        AppendFileStoreCKANDataService appendFileStoreCKANDataService = new AppendFileStoreCKANDataService(name, properties);

        dataFlowNodeLifeCycleControl.completeCreationAndActivateDataFlowNode(UUID.randomUUID().toString(), dummyDataSource, null);
        dataFlowNodeLifeCycleControl.completeCreationAndActivateDataFlowNode(UUID.randomUUID().toString(), appendFileStoreCKANDataService, null);

        ((ObservableDataProvider<String>) dummyDataSource.getDataProvider(String.class)).addDataConsumer((ObserverDataConsumer<String>) appendFileStoreCKANDataService.getDataConsumer(String.class));

        dummyDataSource.sendData("Test Data, Test Text");

        dataFlowNodeLifeCycleControl.removeDataFlowNode(dummyDataSource);
        dataFlowNodeLifeCycleControl.removeDataFlowNode(appendFileStoreCKANDataService);
    }
    catch (Throwable throwable)
    {
        logger.log(Level.WARNING, "Problem in 'AppendFileStoreCKANDataServiceTest.createResourceAsString'", throwable);
        fail("Problem in 'AppendFileStoreCKANDataServiceTest.createResourceAsString': " + throwable);
    }
}

开发者ID:arjuna-technologies，项目名称:CKAN_DataBroker_PlugIn，代码行数:41，代码来源:AppendFileStoreCKANDataServiceTest.java

示例14: createResourceAsBytes

import com.arjuna.databroker.data.connector.ObserverDataConsumer; //导入依赖的package包/类
@Test
public void createResourceAsBytes()
{
    try
    {
        CKANAPIProperties ckanAPIProperties = new CKANAPIProperties("ckanapi.properties");

        if (! ckanAPIProperties.isLoaded())
        {
            logger.log(Level.INFO, "SKIPPING TEST 'AppendFileStoreCKANDataServiceTest.createResourceAsBytes', no propertiles file");
            return;
        }

        DataFlowNodeLifeCycleControl dataFlowNodeLifeCycleControl = new TestJEEDataFlowNodeLifeCycleControl();

        String              name       = "AppendFileStoreCKANDataService";
        Map<String, String> properties = new HashMap<String, String>();
        properties.put(AppendFileStoreCKANDataService.CKANROOTURL_PROPERTYNAME, ckanAPIProperties.getCKANRootURL());
        properties.put(AppendFileStoreCKANDataService.PACKAGEID_PROPERTYNAME, ckanAPIProperties.getPackageId());
        properties.put(AppendFileStoreCKANDataService.APIKEY_PROPERTYNAME, ckanAPIProperties.getAPIKey());

        DummyDataSource                dummyDataSource                = new DummyDataSource("Dummy Data Source", Collections.<String, String>emptyMap());
        AppendFileStoreCKANDataService appendFileStoreCKANDataService = new AppendFileStoreCKANDataService(name, properties);

        dataFlowNodeLifeCycleControl.completeCreationAndActivateDataFlowNode(UUID.randomUUID().toString(), dummyDataSource, null);
        dataFlowNodeLifeCycleControl.completeCreationAndActivateDataFlowNode(UUID.randomUUID().toString(), appendFileStoreCKANDataService, null);

        ((ObservableDataProvider<byte[]>) dummyDataSource.getDataProvider(byte[].class)).addDataConsumer((ObserverDataConsumer<byte[]>) appendFileStoreCKANDataService.getDataConsumer(byte[].class));

        dummyDataSource.sendData("Test Data, Test Text".getBytes());

        dataFlowNodeLifeCycleControl.removeDataFlowNode(dummyDataSource);
        dataFlowNodeLifeCycleControl.removeDataFlowNode(appendFileStoreCKANDataService);
    }
    catch (Throwable throwable)
    {
        logger.log(Level.WARNING, "Problem in 'AppendFileStoreCKANDataServiceTest.createResourceAsBytes'", throwable);
        fail("Problem in 'AppendFileStoreCKANDataServiceTest.createResourceAsBytes': " + throwable);
    }
}

开发者ID:arjuna-technologies，项目名称:CKAN_DataBroker_PlugIn，代码行数:41，代码来源:AppendFileStoreCKANDataServiceTest.java

示例15: simplestConversion

import com.arjuna.databroker.data.connector.ObserverDataConsumer; //导入依赖的package包/类
@Test
@Ignore
public void simplestConversion()
{
    ShapeFile2CSVConverterDataProcessor shapeFileDataProcessor = new ShapeFile2CSVConverterDataProcessor("ShapeFile Converter Data Processor", Collections.<String, String>emptyMap());
    ObserverDataConsumer<File>      dataConsumer           = (ObserverDataConsumer<File>) shapeFileDataProcessor.getDataConsumer(File.class);

    File testFile = new File("/tmp/test.shp");

    dataConsumer.consume(null, testFile);
}

开发者ID:arjuna-technologies，项目名称:GeoTools_DataBroker_PlugIn，代码行数:12，代码来源:ConverterTest.java

示例16: simpleInvocation

import com.arjuna.databroker.data.connector.ObserverDataConsumer; //导入依赖的package包/类
@Test
public void simpleInvocation()
{
    DataFlowNodeLifeCycleControl dataFlowNodeLifeCycleControl = new TestJEEDataFlowNodeLifeCycleControl();

    AuthenticationProperties authenticationProperties = new AuthenticationProperties("authentication.properties");

    String              name       = "Twitter Data Source";
    Map<String, String> properties = new HashMap<String, String>();
    properties.put(TwitterDataSource.TWITTER_CONSUMERKEY_PROPERTYNAME,    authenticationProperties.getConsumerKey());
    properties.put(TwitterDataSource.TWITTER_CONSUMERSECRET_PROPERTYNAME, authenticationProperties.getConsumerSecret());
    properties.put(TwitterDataSource.TWITTER_TOKEN_PROPERTYNAME,          authenticationProperties.getToken());
    properties.put(TwitterDataSource.TWITTER_TOKENSECRET_PROPERTYNAME,    authenticationProperties.getTokenSecret());
    properties.put(TwitterDataSource.TWITTER_TRACKTERM_PROPERTYNAME,      "newcastle");
    properties.put(TwitterDataSource.POLLINTERVAL_PROPERTYNAME,           "5");

    TwitterDataSource  twitterDataSource  = new TwitterDataSource(name, properties);
    DummyDataProcessor dummyDataProcessor = new DummyDataProcessor("Dummy Data Processor", Collections.<String, String>emptyMap());

    dataFlowNodeLifeCycleControl.completeCreationAndActivateDataFlowNode(UUID.randomUUID().toString(), twitterDataSource, null);
    dataFlowNodeLifeCycleControl.completeCreationAndActivateDataFlowNode(UUID.randomUUID().toString(), dummyDataProcessor, null);

    ((ObservableDataProvider<String>) twitterDataSource.getDataProvider(String.class)).addDataConsumer((ObserverDataConsumer<String>) dummyDataProcessor.getDataConsumer(String.class));

    try
    {
        Thread.sleep(60000);
    }
    catch (InterruptedException interruptedException)
    {
        fail("Interrupted during sleep");
    }

    dataFlowNodeLifeCycleControl.removeDataFlowNode(dummyDataProcessor);

    assertTrue("Didn't receive any tweets", dummyDataProcessor.receivedData().size() > 0);
}

开发者ID:arjuna-technologies，项目名称:Twitter_DataBroker_PlugIn，代码行数:38，代码来源:SimpleTest.java

示例17: simpleDecryptInvocation

import com.arjuna.databroker.data.connector.ObserverDataConsumer; //导入依赖的package包/类
@SuppressWarnings("rawtypes")
    @Test
    public void simpleDecryptInvocation()
    {
        try
        {
            int character = 0;
            int index     = 0;

            File         spreadsheetFile        = new File("Test02.xlsx");
            byte[]       spreadsheetData        = new byte[(int) spreadsheetFile.length()];
            InputStream  spreadsheetInputStream = new FileInputStream(spreadsheetFile);
            index     = 0;
            character = spreadsheetInputStream.read();
            while (character != -1)
            {
                spreadsheetData[index] = (byte) character;
                character = spreadsheetInputStream.read();
                index++;
            }
            spreadsheetInputStream.close();

            File         csvFile        = new File("Test01_s.csv");
            byte[]       csvData        = new byte[(int) csvFile.length()];
            InputStream  csvInputStream = new FileInputStream(csvFile);
            index     = 0;
            character = csvInputStream.read();
            while (character != -1)
            {
                csvData[index] = (byte) character;
                character = csvInputStream.read();
                index++;
            }
            csvInputStream.close();

            DataFlowNodeLifeCycleControl     dataFlowNodeLifeCycleControl     = new TestJEEDataFlowNodeLifeCycleControl();
//            DataFlowNodeLinkLifeCycleControl dataFlowNodeLinkLifeCycleControl = new TestJEEDataFlowNodeLinkLifeCycleControl();

            String                            name                              = "XSSF Stream Sheet To CSV Data Processor";
            Map<String, String>               properties                        = Collections.emptyMap();

            DummyDataSource                   dummyDataSource                   = new DummyDataSource("Dummy Data Source", Collections.<String, String>emptyMap());
            XSSFStreamSheetToCSVDataProcessor xssfStreamSheetToCSVDataProcessor = new XSSFStreamSheetToCSVDataProcessor(name, properties);
            DummyDataSink                     dummyDataSink                     = new DummyDataSink("Dummy Data Sink", Collections.<String, String>emptyMap());

            dataFlowNodeLifeCycleControl.completeCreationAndActivateDataFlowNode(UUID.randomUUID().toString(), dummyDataSource, null);
            dataFlowNodeLifeCycleControl.completeCreationAndActivateDataFlowNode(UUID.randomUUID().toString(), xssfStreamSheetToCSVDataProcessor, null);
            dataFlowNodeLifeCycleControl.completeCreationAndActivateDataFlowNode(UUID.randomUUID().toString(), dummyDataSink, null);

            ((ObservableDataProvider<Map>) dummyDataSource.getDataProvider(Map.class)).addDataConsumer((ObserverDataConsumer<Map>) xssfStreamSheetToCSVDataProcessor.getDataConsumer(Map.class));
            ((ObservableDataProvider<Map>) xssfStreamSheetToCSVDataProcessor.getDataProvider(Map.class)).addDataConsumer((ObserverDataConsumer<Map>) dummyDataSink.getDataConsumer(Map.class));

            Map<String, Object> inputMap = new HashMap<String, Object>();
            inputMap.put("filename", "Test.xslx");
            inputMap.put("data", spreadsheetData);
            inputMap.put("password", "test");

            dummyDataSource.sendData(inputMap);

            List<Object> receivedData = dummyDataSink.receivedData();
            assertEquals("Unexpected received data", 1, receivedData.size());

            Map<String, Object> outputMap = (Map<String, Object>) receivedData.get(0);
            assertNotNull("Unexpected null received data", outputMap);
            assertEquals("Unexpected received map size", 3, outputMap.size());
            assertNotNull("Unexpected null 'filename' entry", outputMap.get("filename"));
            assertNotNull("Unexpected null 'data' entry", outputMap.get("data"));
            assertNotNull("Unexpected null 'resourceformat' entry", outputMap.get("resourceformat"));
            assertEquals("Unexpected value of 'filename' entry", "Test_1.csv", outputMap.get("filename"));
            assertArrayEquals("Unexpected value of 'data' entry", csvData, (byte[]) outputMap.get("data"));
            assertEquals("Unexpected value of 'resourceformat' entry", "csv", outputMap.get("resourceformat"));

            dataFlowNodeLifeCycleControl.removeDataFlowNode(dummyDataSource);
            dataFlowNodeLifeCycleControl.removeDataFlowNode(xssfStreamSheetToCSVDataProcessor);
            dataFlowNodeLifeCycleControl.removeDataFlowNode(dummyDataSink);
        }
        catch (IOException ioException)
        {
            fail("IO Exception");
        }
    }

开发者ID:arjuna-technologies，项目名称:Apache-POI_DataBroker_PlugIn，代码行数:82，代码来源:SimpleStreamEncryptedSheetToCSVTest.java

示例18: simpleInvocation

import com.arjuna.databroker.data.connector.ObserverDataConsumer; //导入依赖的package包/类
@SuppressWarnings("rawtypes")
    @Test
    public void simpleInvocation()
    {
        try
        {
            int character = 0;
            int index     = 0;

            File         spreadsheetFile        = new File("Test01.xlsx");
            byte[]       spreadsheetData        = new byte[(int) spreadsheetFile.length()];
            InputStream  spreadsheetInputStream = new FileInputStream(spreadsheetFile);
            index     = 0;
            character = spreadsheetInputStream.read();
            while (character != -1)
            {
                spreadsheetData[index] = (byte) character;
                character = spreadsheetInputStream.read();
                index++;
            }
            spreadsheetInputStream.close();

            File         csvFile        = new File("Test01_s.csv");
            byte[]       csvData        = new byte[(int) csvFile.length()];
            InputStream  csvInputStream = new FileInputStream(csvFile);
            index     = 0;
            character = csvInputStream.read();
            while (character != -1)
            {
                csvData[index] = (byte) character;
                character = csvInputStream.read();
                index++;
            }
            csvInputStream.close();

            DataFlowNodeLifeCycleControl     dataFlowNodeLifeCycleControl     = new TestJEEDataFlowNodeLifeCycleControl();
//            DataFlowNodeLinkLifeCycleControl dataFlowNodeLinkLifeCycleControl = new TestJEEDataFlowNodeLinkLifeCycleControl();

            String                            name                              = "XSSF Stream Sheet To CSV Data Processor";
            Map<String, String>               properties                        = Collections.emptyMap();

            DummyDataSource                   dummyDataSource                   = new DummyDataSource("Dummy Data Source", Collections.<String, String>emptyMap());
            XSSFStreamSheetToCSVDataProcessor xssfStreamSheetToCSVDataProcessor = new XSSFStreamSheetToCSVDataProcessor(name, properties);
            DummyDataSink                     dummyDataSink                     = new DummyDataSink("Dummy Data Sink", Collections.<String, String>emptyMap());

            dataFlowNodeLifeCycleControl.completeCreationAndActivateDataFlowNode(UUID.randomUUID().toString(), dummyDataSource, null);
            dataFlowNodeLifeCycleControl.completeCreationAndActivateDataFlowNode(UUID.randomUUID().toString(), xssfStreamSheetToCSVDataProcessor, null);
            dataFlowNodeLifeCycleControl.completeCreationAndActivateDataFlowNode(UUID.randomUUID().toString(), dummyDataSink, null);

            ((ObservableDataProvider<Map>) dummyDataSource.getDataProvider(Map.class)).addDataConsumer((ObserverDataConsumer<Map>) xssfStreamSheetToCSVDataProcessor.getDataConsumer(Map.class));
            ((ObservableDataProvider<Map>) xssfStreamSheetToCSVDataProcessor.getDataProvider(Map.class)).addDataConsumer((ObserverDataConsumer<Map>) dummyDataSink.getDataConsumer(Map.class));

            Map<String, Object> inputMap = new HashMap<String, Object>();
            inputMap.put("filename", "Test.xslx");
            inputMap.put("data", spreadsheetData);

            dummyDataSource.sendData(inputMap);

            List<Object> receivedData = dummyDataSink.receivedData();
            assertEquals("Unexpected received data", 1, receivedData.size());

            Map<String, Object> outputMap = (Map<String, Object>) receivedData.get(0);
            assertNotNull("Unexpected null received data", outputMap);
            assertEquals("Unexpected received map size", 3, outputMap.size());
            assertNotNull("Unexpected null 'filename' entry", outputMap.get("filename"));
            assertNotNull("Unexpected null 'data' entry", outputMap.get("data"));
            assertNotNull("Unexpected null 'resourceformat' entry", outputMap.get("resourceformat"));
            assertEquals("Unexpected value of 'filename' entry", "Test_1.csv", outputMap.get("filename"));
            assertArrayEquals("Unexpected value of 'data' entry", csvData, (byte[]) outputMap.get("data"));
            assertEquals("Unexpected value of 'resourceformat' entry", "csv", outputMap.get("resourceformat"));

            dataFlowNodeLifeCycleControl.removeDataFlowNode(dummyDataSource);
            dataFlowNodeLifeCycleControl.removeDataFlowNode(xssfStreamSheetToCSVDataProcessor);
            dataFlowNodeLifeCycleControl.removeDataFlowNode(dummyDataSink);
        }
        catch (IOException ioException)
        {
            fail("IO Exception");
        }
    }

开发者ID:arjuna-technologies，项目名称:Apache-POI_DataBroker_PlugIn，代码行数:81，代码来源:SimpleStreamSheetToCSVTest.java

示例19: simpleInvocation

import com.arjuna.databroker.data.connector.ObserverDataConsumer; //导入依赖的package包/类
@SuppressWarnings("rawtypes")
    @Test
    public void simpleInvocation()
    {
        try
        {
            File         spreadsheetFile        = new File("Test01.xlsx");
            byte[]       spreadsheetData        = new byte[(int) spreadsheetFile.length()];
            InputStream  spreadsheetInputStream = new FileInputStream(spreadsheetFile);
            int          character              = spreadsheetInputStream.read();
            int          index                  = 0;
            while (character != -1)
            {
                spreadsheetData[index] = (byte) character;
                character = spreadsheetInputStream.read();
                index++;
            }
            spreadsheetInputStream.close();

            File         csvFile        = new File("Test01_o.csv");
            byte[]       csvData        = new byte[(int) csvFile.length()];
            InputStream  csvInputStream = new FileInputStream(csvFile);
            index     = 0;
            character = csvInputStream.read();
            while (character != -1)
            {
                csvData[index] = (byte) character;
                character = csvInputStream.read();
                index++;
            }
            csvInputStream.close();

            DataFlowNodeLifeCycleControl dataFlowNodeLifeCycleControl = new TestJEEDataFlowNodeLifeCycleControl();
//            DataFlowNodeLinkLifeCycleControl dataFlowNodeLinkLifeCycleControl = new TestJEEDataFlowNodeLinkLifeCycleControl();

            String                      name                        = "XSSF Sheet To CSV Data Processor";
            Map<String, String>         properties                  = Collections.emptyMap();

            DummyDataSource             dummyDataSource             = new DummyDataSource("Dummy Data Source", Collections.<String, String>emptyMap());
            XSSFSheetToCSVDataProcessor xssfSheetToCSVDataProcessor = new XSSFSheetToCSVDataProcessor(name, properties);
            DummyDataSink               dummyDataSink               = new DummyDataSink("Dummy Data Sink", Collections.<String, String>emptyMap());

            dataFlowNodeLifeCycleControl.completeCreationAndActivateDataFlowNode(UUID.randomUUID().toString(), dummyDataSource, null);
            dataFlowNodeLifeCycleControl.completeCreationAndActivateDataFlowNode(UUID.randomUUID().toString(), xssfSheetToCSVDataProcessor, null);
            dataFlowNodeLifeCycleControl.completeCreationAndActivateDataFlowNode(UUID.randomUUID().toString(), dummyDataSink, null);

            ((ObservableDataProvider<Map>) dummyDataSource.getDataProvider(Map.class)).addDataConsumer((ObserverDataConsumer<Map>) xssfSheetToCSVDataProcessor.getDataConsumer(Map.class));
            ((ObservableDataProvider<Map>) xssfSheetToCSVDataProcessor.getDataProvider(Map.class)).addDataConsumer((ObserverDataConsumer<Map>) dummyDataSink.getDataConsumer(Map.class));

            Map<String, Object> inputMap = new HashMap<String, Object>();
            inputMap.put("filename", "Test.xslx");
            inputMap.put("data", spreadsheetData);

            dummyDataSource.sendData(inputMap);

            List<Object> receivedData = dummyDataSink.receivedData();
            assertEquals("Unexpected received data", 1, receivedData.size());

            Map<String, Object> outputMap = (Map<String, Object>) receivedData.get(0);
            assertNotNull("Unexpected null received data", outputMap);
            assertEquals("Unexpected received map size", 3, outputMap.size());
            assertNotNull("Unexpected null 'filename' entry", outputMap.get("filename"));
            assertNotNull("Unexpected null 'data' entry", outputMap.get("data"));
            assertNotNull("Unexpected null 'resourceformat' entry", outputMap.get("resourceformat"));
            assertEquals("Unexpected value of 'filename' entry", "Test_Sheet1.csv", outputMap.get("filename"));
            assertArrayEquals("Unexpected value of 'data' entry", csvData, (byte[]) outputMap.get("data"));
            assertEquals("Unexpected value of 'resourceformat' entry", "csv", outputMap.get("resourceformat"));

            dataFlowNodeLifeCycleControl.removeDataFlowNode(dummyDataSource);
            dataFlowNodeLifeCycleControl.removeDataFlowNode(xssfSheetToCSVDataProcessor);
            dataFlowNodeLifeCycleControl.removeDataFlowNode(dummyDataSink);
        }
        catch (IOException ioException)
        {
            fail("IO Exception");
        }
    }

开发者ID:arjuna-technologies，项目名称:Apache-POI_DataBroker_PlugIn，代码行数:78，代码来源:SimpleSheetToCSVTest.java

示例20: fileScanner01

import com.arjuna.databroker.data.connector.ObserverDataConsumer; //导入依赖的package包/类
@Test
public void fileScanner01()
{
    try
    {
        DataFlowNodeLifeCycleControl dataFlowNodeLifeCycleControl = new TestJEEDataFlowNodeLifeCycleControl();

        File testDirectory = createTemporaryDirectory("Scanner01");

        String              name       = "Polling File Change Data Source";
        Map<String, String> properties = new HashMap<String, String>();
        properties.put(PollingFileChangeDataSource.FILENAME_PROPERYNAME, testDirectory.toString() + File.separator + "Test02");
        properties.put(PollingFileChangeDataSource.POLLINTERVAL_PROPERYNAME, "1000");

        PollingFileChangeDataSource pollingFileChangeDataSource = new PollingFileChangeDataSource(name, properties);
        DummyDataSink               dummyDataSink               = new DummyDataSink("Dummy Data Sink", Collections.<String, String>emptyMap());

        dataFlowNodeLifeCycleControl.completeCreationAndActivateDataFlowNode(UUID.randomUUID().toString(), pollingFileChangeDataSource, null);
        dataFlowNodeLifeCycleControl.completeCreationAndActivateDataFlowNode(UUID.randomUUID().toString(), dummyDataSink, null);

        ((ObservableDataProvider<File>) pollingFileChangeDataSource.getDataProvider(File.class)).addDataConsumer((ObserverDataConsumer<File>) dummyDataSink.getDataConsumer(File.class));

        Thread.sleep(1000);

        File testFile1 = new File(testDirectory, "Test01");
        testFile1.createNewFile();
        Thread.sleep(1000);

        File testFile2 = new File(testDirectory, "Test02");
        testFile2.createNewFile();
        Thread.sleep(1000);

        File testFile3 = new File(testDirectory, "Test03");
        testFile3.createNewFile();
        Thread.sleep(1000);

        dataFlowNodeLifeCycleControl.removeDataFlowNode(pollingFileChangeDataSource);
        dataFlowNodeLifeCycleControl.removeDataFlowNode(dummyDataSink);

        assertEquals("Incorrect message number", 1, dummyDataSink.receivedData().size());
    }
    catch (Throwable throwable)
    {
        logger.log(Level.WARNING, "Problem in 'fileScanner01'", throwable);

        fail("Problem in 'fileScanner01': " + throwable);
    }
}

开发者ID:arjuna-technologies，项目名称:FileSystem_DataBroker_PlugIn，代码行数:49，代码来源:PollingFileChangeDataSourceTest.java

注：本文中的com.arjuna.databroker.data.connector.ObserverDataConsumer类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java HeaderItem类代码示例发布时间：2022-05-22

Java PropertyEventDispatcher类代码示例发布时间：2022-05-22

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：19222|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9996|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8331|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8700|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8644|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9666|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8630|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：8004|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8664|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7539|2022-11-06

客服电话

电子邮件

Java ObserverDataConsumer类代码示例

示例1: simpleInvocation

示例2: simplestConversion

示例3: startupJob

示例4: BatchDataProvider

示例5: getDataConsumers

示例6: addDataConsumer

示例7: removeDataConsumer

示例8: produce

示例9: getDataFlowLinks

示例10: DefaultObservableDataProvider

示例11: DummyObservableDataProvider

示例12: simplestChain

示例13: createResourceAsString

示例14: createResourceAsBytes

示例15: simplestConversion

示例16: simpleInvocation

示例17: simpleDecryptInvocation

示例18: simpleInvocation

示例19: simpleInvocation

示例20: fileScanner01

请发表评论

全部评论

上一篇：

下一篇：

bradtraversy/iweather: Ionic 3 mobile we

微信小程序如何刷新当前界面

joaomh/curso-de-matlab

断牙刷新位置时间（断牙属性及刷新位置介绍

rugk/mastodon-simplified-federation: Sim

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053