本文整理汇总了Java中lotus.domino.Stream类的典型用法代码示例。如果您正苦于以下问题:Java Stream类的具体用法?Java Stream怎么用?Java Stream使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
Stream类属于lotus.domino包,在下文中一共展示了Stream类的14个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: processJava2Domino
import lotus.domino.Stream; //导入依赖的package包/类
public void processJava2Domino(Document docCurrent, Object objCurrent, String strNotesField, String strJavaField, HashMap<String, Object> addValues) {
try {
MimeMultipart body = getValue(objCurrent, strJavaField);
Stream stream = docCurrent.getParentDatabase().getParent().createStream();
if (body != null)
stream.writeText(body.getHTML());
else
return;
MIMEEntity entity = docCurrent.getMIMEEntity(strNotesField);
if (entity == null) {
docCurrent.removeItem(strNotesField);
entity = docCurrent.createMIMEEntity(strNotesField);
}
entity.setContentFromText(stream, "text/html;charset=UTF-8", 1725);
stream.close();
// docCurrent.replaceItemValue(strNotesField, strValue);
} catch (Exception e) {
e.printStackTrace();
}
}
开发者ID:OpenNTF,项目名称:myWebGate-Scrum,代码行数:26,代码来源:MimeMultipartBinder.java
示例2: processJava2Domino
import lotus.domino.Stream; //导入依赖的package包/类
public void processJava2Domino(Document docCurrent, Object objCurrent,
String strNotesField, String strJavaField,
HashMap<String, Object> addValues) {
try {
MimeMultipart body = getValue(objCurrent, strJavaField);
Stream stream = docCurrent.getParentDatabase().getParent().createStream();
stream.writeText(body.getHTML());
MIMEEntity entity = docCurrent.getMIMEEntity(strNotesField);
if(entity == null)
entity = docCurrent.createMIMEEntity(strNotesField);
entity.setContentFromText(stream,"text/html;charset=UTF-8", 1725);
stream.close();
//docCurrent.replaceItemValue(strNotesField, strValue);
} catch (Exception e) {
e.printStackTrace();
}
}
开发者ID:OpenNTF,项目名称:Nagios4DominoIntegration,代码行数:24,代码来源:MimeMultipartBinder.java
示例3: MIMEBufferedInputStream
import lotus.domino.Stream; //导入依赖的package包/类
public MIMEBufferedInputStream(final Stream is, final int size) {
try {
this.is = is;
this.buffer = new byte[size];
this.length = is.getBytes();
} catch (NotesException ne) {
DominoUtils.handleException(ne);
throw new RuntimeException(MIMEBufferedInputStream.class.getName() + " Constructor Failure");
}
// instanceCount++;
// if (++instanceCount % 1000 == 0) {
// System.out.println("Created " + instanceCount + " MIMEInputStream objects...");
// }
}
开发者ID:OpenNTF,项目名称:org.openntf.domino,代码行数:15,代码来源:Streams.java
示例4: getStreamBytes
import lotus.domino.Stream; //导入依赖的package包/类
public static int getStreamBytes(final Stream stream) {
try {
return stream.getBytes();
} catch (NotesException ne) {
DominoUtils.handleException(ne);
}
return 0;
}
开发者ID:OpenNTF,项目名称:org.openntf.domino,代码行数:9,代码来源:Streams.java
示例5: readerToNotesStream
import lotus.domino.Stream; //导入依赖的package包/类
private static void readerToNotesStream(Stream stream, Reader reader) throws IOException, NotesException {
BufferedReader br = new BufferedReader(reader);
String line = br.readLine();
while ( line != null ) {
stream.writeText(line);
stream.writeText("\r\n"); //$NON-NLS-1$
line = br.readLine();
}
}
开发者ID:OpenNTF,项目名称:XPagesExtensionLibrary,代码行数:10,代码来源:MimeMessageParser.java
示例6: inputStreamToNotesStream
import lotus.domino.Stream; //导入依赖的package包/类
private static void inputStreamToNotesStream(Stream stream, InputStream is) throws IOException, NotesException {
int ch = is.read();
while ( ch != -1 ) {
byte b[] = new byte[1];
b[0] = (byte)ch;
stream.write(b);
ch = is.read();
}
}
开发者ID:OpenNTF,项目名称:XPagesExtensionLibrary,代码行数:11,代码来源:MimeMessageParser.java
示例7: saveState
import lotus.domino.Stream; //导入依赖的package包/类
/**
* Save state. Imported from org.openntf.domino
*
* @param object
* the object
* @param doc
* the doc
* @param itemName
* the item name
* @param compress
* the compress
* @throws Throwable
* the throwable
*/
public static void saveState(Serializable object, Document doc, String itemName, boolean compress, Map<String, String> headers) throws Throwable {
Session session=doc.getParentDatabase().getParent();
boolean convertMime = session.isConvertMime();
session.setConvertMime(false);
ByteArrayOutputStream byteStream = new ByteArrayOutputStream();
ObjectOutputStream objectStream = compress ? new ObjectOutputStream(new GZIPOutputStream(byteStream)) : new ObjectOutputStream(
byteStream);
String contentType = null;
// Prefer externalization if available
if(object instanceof Externalizable) {
((Externalizable)object).writeExternal(objectStream);
contentType = "application/x-java-externalized-object";
} else {
objectStream.writeObject(object);
contentType = "application/x-java-serialized-object";
}
objectStream.flush();
objectStream.close();
Stream mimeStream = session.createStream();
MIMEEntity previousState = doc.getMIMEEntity(itemName);
MIMEEntity entity = previousState == null ? doc.createMIMEEntity(itemName) : previousState;
ByteArrayInputStream byteIn = new ByteArrayInputStream(byteStream.toByteArray());
mimeStream.setContents(byteIn);
entity.setContentFromBytes(mimeStream, contentType, MIMEEntity.ENC_NONE);
MIMEHeader contentEncoding = entity.getNthHeader("Content-Encoding");
if (compress) {
if (contentEncoding == null) {
contentEncoding = entity.createHeader("Content-Encoding");
}
contentEncoding.setHeaderVal("gzip");
contentEncoding.recycle();
} else {
if (contentEncoding != null) {
contentEncoding.remove();
contentEncoding.recycle();
}
}
MIMEHeader javaClass = entity.getNthHeader("X-Java-Class");
if (javaClass == null) {
javaClass = entity.createHeader("X-Java-Class");
}
javaClass.setHeaderVal(object.getClass().getName());
javaClass.recycle();
if(headers != null) {
for(Map.Entry<String, String> entry : headers.entrySet()) {
MIMEHeader paramHeader = entity.getNthHeader(entry.getKey());
if(paramHeader == null) {
paramHeader = entity.createHeader(entry.getKey());
}
paramHeader.setHeaderVal(entry.getValue());
paramHeader.recycle();
}
}
entity.recycle();
mimeStream.recycle();
session.setConvertMime(convertMime);
}
开发者ID:sbasegmez,项目名称:Blogged,代码行数:79,代码来源:DevelopiUtils.java
示例8: processJava2Domino
import lotus.domino.Stream; //导入依赖的package包/类
public MimeMultipart[] processJava2Domino(Document docCurrent, Object objCurrent, Definition def) {
MimeMultipart[] mpRC = new MimeMultipart[2];
Logger log = LoggerFactory.getLogger(this.getClass().getCanonicalName());
try {
MimeMultipart oldBody = getRawValueFromStore(docCurrent, def.getNotesField());
MimeMultipart body = getValue(objCurrent, def.getJavaField());
mpRC[0] = oldBody;
mpRC[1] = body;
log.fine("oldBody = " + oldBody);
log.fine("body = " + body);
Stream stream = docCurrent.getParentDatabase().getParent().createStream();
if (body != null)
stream.writeText(body.getHTML());
else
return null;
MIMEEntity entity = docCurrent.getMIMEEntity(def.getNotesField());
log.info("entity = " + entity);
if (entity == null) {
docCurrent.removeItem(def.getNotesField());
log.info("creating Entity for " + def.getNotesField());
entity = docCurrent.createMIMEEntity(def.getNotesField());
log.info("new entity created");
}
stream.setPosition(0);
entity.setContentFromText(stream, "text/html;charset=UTF-8", 1725);
stream.close();
log.info("done");
} catch (Exception e) {
LoggerFactory.logWarning(this.getClass(), "Error during processJava2Domino", e);
throw new XPTRuntimeException("Error during processJava2Domino", e);
}
return mpRC;
}
开发者ID:OpenNTF,项目名称:XPagesToolkit,代码行数:38,代码来源:MimeMultipartBinder.java
示例9: getContentsAsText
import lotus.domino.Stream; //导入依赖的package包/类
private String getContentsAsText(MIMEEntity child, Session sesCurrent) throws NotesException {
Stream stream = sesCurrent.createStream();
child.getContentAsText(stream, true);
stream.setPosition(0);
String str = stream.readText();
stream.recycle();
return str;
}
开发者ID:OpenNTF,项目名称:XPagesToolkit,代码行数:9,代码来源:MimeMultipartBinder.java
示例10: readStream
import lotus.domino.Stream; //导入依赖的package包/类
public static byte[] readStream(final Stream stream, final int length) {
try {
return stream.read(length);
} catch (NotesException ne) {
DominoUtils.handleException(ne);
return null;
}
}
开发者ID:OpenNTF,项目名称:org.openntf.domino,代码行数:9,代码来源:Streams.java
示例11: getStreamPosition
import lotus.domino.Stream; //导入依赖的package包/类
public static int getStreamPosition(final Stream stream) {
try {
return stream.getPosition();
} catch (NotesException ne) {
DominoUtils.handleException(ne);
return -1;
}
}
开发者ID:OpenNTF,项目名称:org.openntf.domino,代码行数:9,代码来源:Streams.java
示例12: setStreamPosition
import lotus.domino.Stream; //导入依赖的package包/类
public static boolean setStreamPosition(final Stream stream, final int position) {
try {
stream.setPosition(position);
return true;
} catch (NotesException ne) {
DominoUtils.handleException(ne);
return false;
}
}
开发者ID:OpenNTF,项目名称:org.openntf.domino,代码行数:10,代码来源:Streams.java
示例13: processJava2Domino
import lotus.domino.Stream; //导入依赖的package包/类
public Object[] processJava2Domino(Document docCurrent, Object objCurrent, Definition def) {
Object[] objRC = new Object[2];
try {
Object oldBody = getRawValueFromStore(docCurrent, def.getNotesField());
Object body = getValue(objCurrent, def.getJavaField());
objRC[0] = oldBody;
objRC[1] = body;
Session session = docCurrent.getParentDatabase().getParent();
boolean convertMime = session.isConvertMime();
session.setConvertMime(false);
ByteArrayOutputStream byteStream = new ByteArrayOutputStream();
ObjectOutputStream objectStream = new ObjectOutputStream(new GZIPOutputStream(byteStream));
objectStream.writeObject(body);
objectStream.flush();
objectStream.close();
MIMEEntity entity = null;
MIMEEntity previousState = docCurrent.getMIMEEntity(def.getNotesField());
if (previousState == null) {
entity = docCurrent.createMIMEEntity(def.getNotesField());
} else {
entity = previousState;
}
Stream mimeStream = session.createStream();
ByteArrayInputStream byteIn = new ByteArrayInputStream(byteStream.toByteArray());
mimeStream.setContents(byteIn);
entity.setContentFromBytes(mimeStream, "application/x-java-serialized-object", MIMEEntity.ENC_NONE);
MIMEHeader header = entity.getNthHeader("Content-Encoding");
if (header == null) {
header = entity.createHeader("Content-Encoding");
}
header.setHeaderVal("gzip");
header.recycle();
entity.recycle();
mimeStream.recycle();
session.setConvertMime(convertMime);
} catch (Exception e) {
LoggerFactory.logWarning(getClass(), "Error during processJava2Domino", e);
}
return objRC;
}
开发者ID:OpenNTF,项目名称:XPagesToolkit,代码行数:49,代码来源:ObjectBinder.java
示例14: get
import lotus.domino.Stream; //导入依赖的package包/类
public static InputStream get(final Stream source) {
return source != null ? new MIMEBufferedInputStream(source) : null;
}
开发者ID:OpenNTF,项目名称:org.openntf.domino,代码行数:4,代码来源:Streams.java
注:本文中的lotus.domino.Stream类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论