Author: kwright
Date: Mon Dec 22 10:56:10 2014
New Revision: 1647285
URL: http://svn.apache.org/r1647285
Log:
Add session support
Added:
manifoldcf/branches/CONNECTORS-1119/connectors/email/connector/src/main/java/org/apache/manifoldcf/crawler/notifications/email/EmailSession.java
(with props)
Added:
manifoldcf/branches/CONNECTORS-1119/connectors/email/connector/src/main/java/org/apache/manifoldcf/crawler/notifications/email/EmailSession.java
URL:
http://svn.apache.org/viewvc/manifoldcf/branches/CONNECTORS-1119/connectors/email/connector/src/main/java/org/apache/manifoldcf/crawler/notifications/email/EmailSession.java?rev=1647285&view=auto
==============================================================================
---
manifoldcf/branches/CONNECTORS-1119/connectors/email/connector/src/main/java/org/apache/manifoldcf/crawler/notifications/email/EmailSession.java
(added)
+++
manifoldcf/branches/CONNECTORS-1119/connectors/email/connector/src/main/java/org/apache/manifoldcf/crawler/notifications/email/EmailSession.java
Mon Dec 22 10:56:10 2014
@@ -0,0 +1,133 @@
+/**
+* Licensed to the Apache Software Foundation (ASF) under one or more
+* contributor license agreements. See the NOTICE file distributed with
+* this work for additional information regarding copyright ownership.
+* The ASF licenses this file to You under the Apache License, Version 2.0
+* (the "License"); you may not use this file except in compliance with
+* the License. You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+
+package org.apache.manifoldcf.crawler.notifications.email;
+
+import java.io.*;
+import java.util.*;
+import javax.mail.*;
+import javax.mail.internet.MimeBodyPart;
+import javax.mail.internet.MimeMessage;
+import javax.mail.search.*;
+
+/** This class represents a raw email session, without any protection
+* from threads waiting on sockets, etc.
+*/
+public class EmailSession
+{
+ protected final String server;
+ protected final int port;
+ protected final String username;
+ protected final String password;
+ protected final String protocol;
+ protected final Properties properties;
+
+ private Session session = null;
+ private Store store = null;
+
+ /** Create a session */
+ public EmailSession(String server, int port, String username, String
password,
+ String protocol, Properties properties)
+ throws MessagingException
+ {
+ this.server = server;
+ this.port = port;
+ this.username = username;
+ this.password = password;
+ this.protocol = protocol;
+ this.properties = properties;
+
+ // Now, try to connect
+ Session thisSession = Session.getDefaultInstance(properties, null);
+ Store thisStore = thisSession.getStore(protocol);
+ thisStore.connect(server, port, username, password);
+
+ session = thisSession;
+ store = thisStore;
+ }
+
+ public String[] listFolders()
+ throws MessagingException
+ {
+ if (store != null)
+ {
+ List<String> folderList = new ArrayList<String>();
+ Folder[] folders = store.getDefaultFolder().list("*");
+ for (Folder folder : folders)
+ {
+ if ((folder.getType() & Folder.HOLDS_MESSAGES) != 0)
+ folderList.add(folder.getFullName());
+ }
+ String[] rval = folderList.toArray(new String[0]);
+ java.util.Arrays.sort(rval);
+ return rval;
+ }
+ return null;
+ }
+
+ public void checkConnection()
+ throws MessagingException
+ {
+ if (store != null)
+ {
+ if (store.getDefaultFolder() == null) {
+ throw new MessagingException("Error checking the connection: No
default folder.");
+ }
+ }
+ }
+
+ public Folder openFolder(String folderName)
+ throws MessagingException
+ {
+ if (store != null)
+ {
+ Folder thisFolder = store.getFolder(folderName);
+ thisFolder.open(Folder.READ_ONLY);
+ return thisFolder;
+ }
+ return null;
+ }
+
+ public void closeFolder(Folder folder)
+ throws MessagingException
+ {
+ folder.close(false);
+ }
+
+ public Message[] getMessages(Folder folder)
+ throws MessagingException
+ {
+ return folder.getMessages();
+ }
+
+ public Message[] search(Folder folder, SearchTerm searchTerm)
+ throws MessagingException
+ {
+ return folder.search(searchTerm);
+ }
+
+ public void close()
+ throws MessagingException
+ {
+ if (store != null)
+ {
+ store.close();
+ store = null;
+ }
+ session = null;
+ }
+}
\ No newline at end of file
Propchange:
manifoldcf/branches/CONNECTORS-1119/connectors/email/connector/src/main/java/org/apache/manifoldcf/crawler/notifications/email/EmailSession.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange:
manifoldcf/branches/CONNECTORS-1119/connectors/email/connector/src/main/java/org/apache/manifoldcf/crawler/notifications/email/EmailSession.java
------------------------------------------------------------------------------
svn:keywords = Id
