Package org.apache.tuscany.sca.demos.aggregator.types

Examples of org.apache.tuscany.sca.demos.aggregator.types.AlertType

67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
        // Aggregate entries from feed1 and feed2
        try {       
            AlertsType alerts = this.alerts.getAllNewAlerts("");
           
            for( Object alertObject : alerts.getAlert() ){        
                AlertType alert = ((AlertType)alertObject);
                Entry entry = factory.newEntry();
                entry.setTitle(alert.getTitle());
                //entry.(alert.getSummary());                   
                entry.addLink(alert.getAddress());
                entry.setPublished(dateFormatter.parse(alert.getDate()));
                       
                feed.addEntry(entry);
            }
        } catch(Exception ex) {
            System.err.println("Exception " + ex.toString());
View Full Code Here
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
        // Aggregate entries from feed1 and feed2
        try {       
            AlertsType alerts = this.alerts.getAllNewAlerts("");
           
            for( Object alertObject : alerts.getAlert() ){        
                AlertType alert = ((AlertType)alertObject);
                Entry entry = factory.newEntry();
                entry.setTitle(alert.getTitle());
                //entry.(alert.getSummary());                   
                entry.addLink(alert.getAddress());
                entry.setPublished(dateFormatter.parse(alert.getDate()));
                       
                feed.addEntry(entry);
            }
        } catch(Exception ex) {
            System.err.println("Exception " + ex.toString());
View Full Code Here
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
            List entries = feed.getEntries();
            for(Object entry: entries){
                SyndEntry syndEntry = (SyndEntry)entry;            
               
                if (syndEntry.getPublishedDate().after(timestamp)){
                    AlertType newAlert = factory.createAlertType();
                   
                    newAlert.setTitle(syndEntry.getTitle());
                 //   newAlert.setSummary("<![CDATA[" +
                //                        syndEntry.getDescription().getValue() +
                //                        "]]>");
                    newAlert.setSummary("");                   
                    newAlert.setAddress(syndEntry.getLink());
                    newAlert.setDate(dateFormatter.format(syndEntry.getPublishedDate()));
                    newAlert.setId(rssaddress);
                    newAlert.setUnread(true);
                   
                    returnAlertList.add(newAlert);
                }
            }
           
View Full Code Here
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
        // Aggregate entries from feed1 and feed2
        try {       
            AlertsType alerts = this.alerts.getAllNewAlerts("");
           
            for( Object alertObject : alerts.getAlert() ){        
                AlertType alert = ((AlertType)alertObject);
                Entry entry = factory.newEntry();
                entry.setTitle(alert.getTitle());
                //entry.(alert.getSummary());                   
                entry.addLink(alert.getAddress());
                entry.setPublished(dateFormatter.parse(alert.getDate()));
                       
                feed.addEntry(entry);
            }
        } catch(Exception ex) {
            System.err.println("Exception " + ex.toString());
View Full Code Here
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
                    ((AlertType)alert).setSourceId(sourceType.getId());
                   
                    // convert from SDO to POJO so that the
                    // JSONRPC binding will work. It can't currently
                    // handle SDOs
                    AlertType newAlert = new AlertTypeNonSDOImpl();
   
                    newAlert.setSourceId(((AlertType)alert).getSourceId());
                    newAlert.setTitle(((AlertType)alert).getTitle());
                    newAlert.setSummary(((AlertType)alert).getSummary());                   
                    newAlert.setAddress(((AlertType)alert).getAddress());
                    newAlert.setDate(((AlertType)alert).getDate());
                    newAlert.setId(((AlertType)alert).getId());
                    newAlert.setUnread(((AlertType)alert).isUnread());               
                   
                    returnAlertList.add(newAlert);
                }
               
                // update the time last checked for this source
View Full Code Here
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
       
        try {       
            AlertsType alerts = this.alerts.getAllNewAlerts("");
           
            for( Object alertObject : alerts.getAlert() ){        
                AlertType alert = ((AlertType)alertObject);
                SyndEntry entry = new SyndEntryImpl();
                entry.setTitle(alert.getTitle());
                //entry.(alert.getSummary());                   
                entry.setLink(alert.getAddress());
                entry.setPublishedDate(dateFormatter.parse(alert.getDate()));
                       
                entries.add(entry);
            }
        } catch(Exception ex) {
            System.err.println("Exception " + ex.toString());
View Full Code Here
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
                    ((AlertType)alert).setSourceId(sourceType.getId());
                   
                    // convert from SDO to POJO so that the
                    // JSONRPC binding will work. It can't currently
                    // handle SDOs
                    AlertType newAlert = new AlertTypeNonSDOImpl();
   
                    newAlert.setSourceId(((AlertType)alert).getSourceId());
                    newAlert.setTitle(((AlertType)alert).getTitle());
                    newAlert.setSummary(((AlertType)alert).getSummary());                   
                    newAlert.setAddress(((AlertType)alert).getAddress());
                    newAlert.setDate(((AlertType)alert).getDate());
                    newAlert.setId(((AlertType)alert).getId());
                    newAlert.setUnread(((AlertType)alert).isUnread());               
                   
                    returnAlertList.add(newAlert);
                }
               
                // update the time last checked for this source
View Full Code Here
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
       
        try {       
            AlertsType alerts = this.alerts.getAllNewAlerts("");
           
            for( Object alertObject : alerts.getAlert() ){        
                AlertType alert = ((AlertType)alertObject);
                SyndEntry entry = new SyndEntryImpl();
                entry.setTitle(alert.getTitle());
                //entry.(alert.getSummary());                   
                entry.setLink(alert.getAddress());
                entry.setPublishedDate(dateFormatter.parse(alert.getDate()));
                       
                entries.add(entry);
            }
        } catch(Exception ex) {
            System.err.println("Exception " + ex.toString());
View Full Code Here
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
            for(Object entry: entries){
                SyndEntry syndEntry = (SyndEntry)entry;            
               
                // System.err.println( "Entry pubdate=" + syndEntry.getPublishedDate() );
                if (syndEntry.getPublishedDate().after(timestamp)){
                    AlertType newAlert = factory.createAlertType();
                   
                    newAlert.setTitle(syndEntry.getTitle());
                 //   newAlert.setSummary("<![CDATA[" +
                //                        syndEntry.getDescription().getValue() +
                //                        "]]>");
                    newAlert.setSummary("");                   
                    newAlert.setAddress(syndEntry.getLink());
                    newAlert.setDate(feedDateFormatter.format(syndEntry.getPublishedDate()));
                    newAlert.setId(rssaddress);
                    newAlert.setUnread(true);
                   
                    returnAlertList.add(newAlert);
                }
            }
           
View Full Code Here
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
                    ((AlertType)alert).setSourceId(sourceType.getId());
                   
                    // convert from SDO to POJO so that the
                    // JSONRPC binding will work. It can't currently
                    // handle SDOs
                    AlertType newAlert = new AlertTypeNonSDOImpl();
   
                    newAlert.setSourceId(((AlertType)alert).getSourceId());
                    newAlert.setTitle(((AlertType)alert).getTitle());
                    newAlert.setSummary(((AlertType)alert).getSummary());                   
                    newAlert.setAddress(((AlertType)alert).getAddress());
                    newAlert.setDate(((AlertType)alert).getDate());
                    newAlert.setId(((AlertType)alert).getId());
                    newAlert.setUnread(((AlertType)alert).isUnread());               
                   
                    returnAlertList.add(newAlert);
                }
               
                // update the time last checked for this source
View Full Code Here
TOP

Related Classes of org.apache.tuscany.sca.demos.aggregator.types.AlertType

  • org.apache.tuscany.sca.demos.aggregator.AlertsFeedServiceImpl
  • org.apache.tuscany.sca.demos.aggregator.AlertsServiceImpl
  • org.apache.tuscany.sca.demos.aggregator.RSSCheckerServiceImpl
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.